- Sort Score
- Num 10 results
- Language All
Results 641 - 650 of 749 for channels (0.05 seconds)
-
android/guava/src/com/google/common/base/Throwables.java
* Gets a {@code Throwable} cause chain as a list. The first entry in the list will be {@code * throwable} followed by its cause hierarchy. Note that this is a snapshot of the cause chain and * will not reflect any subsequent changes to the cause chain. * * <p>Here's an example of how it can be used to find specific types of exceptions in the cause * chain: * * <pre>Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 20.6K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java
Set<Entry<K, V>> es = entrySet; return (es != null) ? es : (entrySet = new EntrySet(this)); } /** * Custom Entry class used by EntryIterator.next(), that relays setValue changes to the underlying * map. */ private final class WriteThroughEntry implements Entry<K, V> { final K key; V value; WriteThroughEntry(K key, V value) { this.key = checkNotNull(key);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 21.6K bytes - Click Count (0) -
docs/zh/docs/tutorial/first-steps.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:06:37 GMT 2026 - 13.3K bytes - Click Count (0) -
cmd/storage-rest-client.go
stat = append(stat, st) } return stat, toStorageErr(err) } // ReadMultiple will read multiple files and send each back as response. // Files are read and returned in the given order. // The resp channel is closed before the call returns. // Only a canceled context or network errors returns an error. func (client *storageRESTClient) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
readBytes.update(acknowledged = unacknowledgedBytesRead) } } else if (!finished && errorExceptionToDeliver == null) { // Nothing to do. Wait until that changes then try again. waitForIo() tryAgain = true } } finally { if (doReadTimeout) { readTimeout.exitAndThrowIfTimedOut() }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jul 07 18:57:05 GMT 2025 - 22.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/Ordering.java
* Ordering} to be of type {@code Comparator} instead. However, at this time we have no plan to * <i>deprecate</i> this class. * * <p>Many replacements involve adopting {@code Stream}, and these changes can sometimes make your * code verbose. Whenever following this advice, you should check whether {@code Stream} could be * adopted more comprehensively in your code; the end result may be quite a bit simpler. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 39.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Sets.java
} }; } /** * Returns the elements of {@code unfiltered} that satisfy a predicate. The returned set is a live * view of {@code unfiltered}; changes to one affect the other. * * <p>The resulting set's iterator does not support {@code remove()}, but all other set methods * are supported. When given an element that doesn't satisfy the predicate, the set's {@codeCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 81.4K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* deep support for asynchronous operations</a>. But if you want to migrate to Caffeine with minimal * code changes, you can use <a * href="https://www.javadoc.io/doc/com.github.ben-manes.caffeine/guava/latest/com.github.benmanes.caffeine.guava/com/github/benmanes/caffeine/guava/CaffeinatedGuava.html">its
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 52K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
) { } /** * Invoked when a call is canceled. * * Like all methods in this interface, this is invoked on the thread that triggered the event. But * while other events occur sequentially; cancels may occur concurrently with other events. For * example, thread A may be executing [responseBodyStart] while thread B executes [canceled]. * Implementations must support such concurrent calls. *Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Ascii.java
* maxLength} chars in length and will end with the given {@code truncationIndicator}. Otherwise, * the sequence will be returned as a string with no changes to the content. * * <p>Examples: * * {@snippet : * Ascii.truncate("foobar", 7, "..."); // returns "foobar" * Ascii.truncate("foobar", 5, "..."); // returns "fo..." * } *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 21.7K bytes - Click Count (0)