- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 659 for consumer (0.07 seconds)
-
android/guava/src/com/google/common/collect/Iterables.java
* <p>To get the only element in a single-element {@code Iterable}, consider using {@link * #getOnlyElement(Iterable)} or {@link #getOnlyElement(Iterable, Object)} instead. * * <p><b>{@code Stream} equivalent:</b> {@code stream.findFirst().orElse(defaultValue)} * * <p><b>Java 21+ users:</b> if {code iterable} is a {@code SequencedCollection} (e.g., any list),Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 16 18:35:28 GMT 2025 - 43.8K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } System.out.println("REQUEST 2 (pooled connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 5.3K bytes - Click Count (0) -
guava/src/com/google/common/cache/ForwardingLoadingCache.java
@CanIgnoreReturnValue // TODO(b/27479612): consider removing this @Override public V get(K key) throws ExecutionException { return delegate().get(key); } @CanIgnoreReturnValue // TODO(b/27479612): consider removing this @Override public V getUnchecked(K key) { return delegate().getUnchecked(key); } @CanIgnoreReturnValue // TODO(b/27479612): consider removing this @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 3K bytes - Click Count (0) -
guava/src/com/google/common/collect/ForwardingDeque.java
@ParametricNullness public E getLast() { return delegate().getLast(); } @CanIgnoreReturnValue // TODO(cpovirk): Consider removing this? @Override public boolean offerFirst(@ParametricNullness E e) { return delegate().offerFirst(e); } @CanIgnoreReturnValue // TODO(cpovirk): Consider removing this? @Override public boolean offerLast(@ParametricNullness E e) { return delegate().offerLast(e); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
@CanIgnoreReturnValue // TODO(kak): consider removing this @Override public <T> T newProxy( T target, Class<T> interfaceType, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(target); checkNotNull(interfaceType); checkNotNull(timeoutUnit); return target; // ha ha } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override @ParametricNullness
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
import okhttp3.internal.http.parseChallenges import okio.Buffer import okio.Socket /** * An HTTP response. Instances of this class are not immutable: the response body is a one-shot * value that may be consumed only once and then closed. All other properties are immutable. * * This class implements [Closeable]. Closing it simply closes its response body. See * [ResponseBody] for an explanation and examples. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jul 28 14:39:28 GMT 2025 - 18.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
return delegate().drainTo(c); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offer(e, timeout, unit); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/ioctl/ValidateNegotiateInfoResponseTest.java
@Test @DisplayName("Test decode returns correct bytes consumed") void testDecodeBytesConsumed() throws SMBProtocolDecodingException { // Prepare minimal buffer byte[] buffer = new byte[24]; // Test with offset 0 int bytesDecoded = response.decode(buffer, 0, 24); assertEquals(24, bytesDecoded, "Should return 24 bytes consumed from offset 0"); // Test with different offsetCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 10.8K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/ForwardingLoadingCache.java
@CanIgnoreReturnValue // TODO(b/27479612): consider removing this @Override public V get(K key) throws ExecutionException { return delegate().get(key); } @CanIgnoreReturnValue // TODO(b/27479612): consider removing this @Override public V getUnchecked(K key) { return delegate().getUnchecked(key); } @CanIgnoreReturnValue // TODO(b/27479612): consider removing this @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/HashMultimap.java
@VisibleForTesting transient int expectedValuesPerKey = DEFAULT_VALUES_PER_KEY; /** * Creates a new, empty {@code HashMultimap} with the default initial capacities. * * <p>You may also consider the equivalent {@code * MultimapBuilder.hashKeys().hashSetValues().build()}, which provides more control over the * underlying data structure. */ public static <K extends @Nullable Object, V extends @Nullable Object>Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 5.8K bytes - Click Count (0)