Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 659 for consumer (0.07 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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 offset
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top