- Sort Score
- Result 10 results
- Languages All
Results 401 - 410 of 466 for consumer (0.09 sec)
-
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) -
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#ReaderRegistered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Feb 07 01:08:54 UTC 2025 - 51.6K bytes - Viewed (0) -
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 atRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 26.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)