Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 211 for reducer (0.19 sec)

  1. android/guava/src/com/google/common/base/Supplier.java

     *
     * <p>This interface is now a legacy type. Use {@code java.util.function.Supplier} (or the
     * appropriate primitive specialization such as {@code IntSupplier}) instead whenever possible.
     * Otherwise, at least reduce <i>explicit</i> dependencies on this type by using lambda expressions
     * or method references instead of classes, leaving your code easier to migrate in the future.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 15 12:15:07 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/testing/DummyProxy.java

          return DummyProxy.this;
        }
    
        @Override
        public String toString() {
          return "Dummy proxy for " + interfaceType;
        }
    
        // Since type variables aren't serializable, reduce the type down to raw type before
        // serialization.
        private Object writeReplace() {
          return new DummyHandler(TypeToken.of(interfaceType.getRawType()));
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 08 17:31:55 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/reader.go

    			need = 1 // to ensure we read at least one byte for every Read
    			tokens = b
    		}
    	} else { // all tokens go towards payload
    		need = int(math.Min(float64(b), float64(need)))
    		tokens = need
    	}
    	// reduce tokens requested according to availability
    	av := int(r.throttle.Tokens())
    	if av < tokens && av > 0 {
    		tokens = av
    		need = int(math.Min(float64(tokens), float64(need)))
    	}
    	err = r.throttle.WaitN(r.ctx, tokens)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

       *
       * <p>CharStreams.copy was failing to clear its CharBuffer after each read call, which effectively
       * reduced the available size of the buffer each time a call to read didn't fill up the available
       * space in the buffer completely. In general this is a performance problem since the buffer size
       * is permanently reduced, but with certain Reader implementations it could also cause the buffer
       * size to reach 0, causing an infinite loop.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/CharStreamsTest.java

       *
       * <p>CharStreams.copy was failing to clear its CharBuffer after each read call, which effectively
       * reduced the available size of the buffer each time a call to read didn't fill up the available
       * space in the buffer completely. In general this is a performance problem since the buffer size
       * is permanently reduced, but with certain Reader implementations it could also cause the buffer
       * size to reach 0, causing an infinite loop.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/base/Predicate.java

     *
     * <p>This interface is now a legacy type. Use {@code java.util.function.Predicate} (or the
     * appropriate primitive specialization such as {@code IntPredicate}) instead whenever possible.
     * Otherwise, at least reduce <i>explicit</i> dependencies on this type by using lambda expressions
     * or method references instead of classes, leaving your code easier to migrate in the future.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 15 16:12:13 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/Connection.kt

     * one or more streams, and then released. An allocated connection won't be stolen by other calls
     * while a redirect or authorization challenge is being handled.
     *
     * When the maximum concurrent streams limit is reduced, some allocations will be rescinded.
     * Attempting to create new streams on these allocations will fail.
     *
     * Note that an allocation may be released before its stream is completed. This is intended to make
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Streams.java

        R apply(double from, long index);
      }
    
      /**
       * Returns the last element of the specified stream, or {@link java.util.Optional#empty} if the
       * stream is empty.
       *
       * <p>Equivalent to {@code stream.reduce((a, b) -> b)}, but may perform significantly better. This
       * method's runtime will be between O(log n) and O(n), performing better on <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Predicate.java

     *
     * <p>This interface is now a legacy type. Use {@code java.util.function.Predicate} (or the
     * appropriate primitive specialization such as {@code IntPredicate}) instead whenever possible.
     * Otherwise, at least reduce <i>explicit</i> dependencies on this type by using lambda expressions
     * or method references instead of classes, leaving your code easier to migrate in the future.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 15 16:12:13 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt

    import okhttp3.internal.connection.RealConnectionPool
    import okhttp3.internal.connection.RealRoutePlanner
    import okhttp3.internal.connection.RouteDatabase
    
    /**
     * Manages reuse of HTTP and HTTP/2 connections for reduced network latency. HTTP requests that
     * share the same [Address] may share a [Connection]. This class implements the policy
     * of which connections to keep open for future use.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 03 20:39:41 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top