Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 466 for consumer (0.09 sec)

  1. docs/en/docs/release-notes.md

    * Clarify function name in example in docs. PR [#1121](https://github.com/tiangolo/fastapi/pull/1121) by [@tmsick](https://github.com/tmsick).
    * Add external link [Apache Kafka producer and consumer with FastAPI and aiokafka](https://iwpnd.pw/articles/2020-03/apache-kafka-fastapi-geostream) to docs. PR [#1112](https://github.com/tiangolo/fastapi/pull/1112) by [@iwpnd](https://github.com/iwpnd).
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
  2. src/bufio/bufio_test.go

    type eofReader struct {
    	buf []byte
    }
    
    func (r *eofReader) Read(p []byte) (int, error) {
    	read := copy(p, r.buf)
    	r.buf = r.buf[read:]
    
    	switch read {
    	case 0, len(r.buf):
    		// As allowed in the documentation, this will return io.EOF
    		// in the same call that consumes the last of the data.
    		// https://godoc.org/io#Reader
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/base/Predicates.java

       * the given class. If the object being tested is {@code null} this predicate evaluates to {@code
       * false}.
       *
       * <p>If you want to filter an {@code Iterable} to narrow its type, consider using {@link
       * com.google.common.collect.Iterables#filter(Iterable, Class)} in preference.
       *
       * <p><b>Warning:</b> contrary to the typical assumptions about predicates (as documented at
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  4. src/bufio/bufio.go

    	b.lastByte = -1
    	b.lastRuneSize = -1
    	return nil
    }
    
    // ReadRune reads a single UTF-8 encoded Unicode character and returns the
    // rune and its size in bytes. If the encoded rune is invalid, it consumes one byte
    // and returns unicode.ReplacementChar (U+FFFD) with a size of 1.
    func (b *Reader) ReadRune() (r rune, size int, err error) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/FluentIterable.java

          return Optional.of(list.get(list.size() - 1));
        }
        Iterator<E> iterator = iterable.iterator();
        if (!iterator.hasNext()) {
          return Optional.absent();
        }
    
        /*
         * TODO(kevinb): consider whether this "optimization" is worthwhile. Users with SortedSets tend
         * to know they are SortedSets and probably would not call this method.
         */
        if (iterable instanceof SortedSet) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 35.3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/FluentIterable.java

          return Optional.of(list.get(list.size() - 1));
        }
        Iterator<E> iterator = iterable.iterator();
        if (!iterator.hasNext()) {
          return Optional.absent();
        }
    
        /*
         * TODO(kevinb): consider whether this "optimization" is worthwhile. Users with SortedSets tend
         * to know they are SortedSets and probably would not call this method.
         */
        if (iterable instanceof SortedSet) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  7. docs/smb3-features/03-multi-channel-design.md

                if (channel.getErrorRate() > 0.1) {
                    log.warn("High error rate on channel {}: {}", 
                        channel.getChannelId(), channel.getErrorRate());
                    // Consider removing channel
                }
            }
        }
        
        private void discoverInterfaces() {
            if (!multiChannelEnabled) return;
            
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  8. docs/smb3-features/06-witness-protocol-design.md

            log.warn("Network partition detected - witness notifications may be delayed");
            
            // Switch to more aggressive connection retry
            // Increase heartbeat frequency
            // Consider fallback mechanisms
        }
        
        public void handlePartitionRecovery() {
            log.info("Network partition recovered - resuming normal witness operations");
            
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 42K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Sets.java

       *
       * <p><b>Note:</b> if mutability is not required, use {@link ImmutableSet#of()} instead. If {@code
       * E} is an {@link Enum} type, use {@link EnumSet#noneOf} instead. Otherwise, strongly consider
       * using a {@code LinkedHashSet} instead, at the cost of increased memory footprint, to get
       * deterministic iteration behavior.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 81.6K bytes
    - Viewed (0)
  10. docs/es/docs/async.md

    * una operación de API remota
    * que una operación de base de datos termine
    * que una query de base de datos devuelva los resultados
    * etc.
    
    Como el tiempo de ejecución se consume principalmente esperando operaciones de <abbr title="Input and Output">I/O</abbr>, las llaman operaciones "I/O bound".
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24.7K bytes
    - Viewed (0)
Back to top