- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 530 for consumer (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
android/guava-testlib/src/com/google/common/testing/TestLogHandler.java
synchronized (lock) { list.clear(); } } /** Returns a snapshot of the logged records. */ /* * TODO(cpovirk): consider higher-level APIs here (say, assertNoRecordsLogged(), * getOnlyRecordLogged(), getAndClearLogRecords()...) * * TODO(cpovirk): consider renaming this method to reflect that it takes a snapshot (and/or return * an ImmutableList) */ public List<LogRecord> getStoredLogRecords() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.8K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/TestLogHandler.java
synchronized (lock) { list.clear(); } } /** Returns a snapshot of the logged records. */ /* * TODO(cpovirk): consider higher-level APIs here (say, assertNoRecordsLogged(), * getOnlyRecordLogged(), getAndClearLogRecords()...) * * TODO(cpovirk): consider renaming this method to reflect that it takes a snapshot (and/or return * an ImmutableList) */ public List<LogRecord> getStoredLogRecords() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
import java.util.concurrent.TimeoutException; /** * Base class for services that can implement {@link #startUp}, {@link #run} and {@link #shutDown} * methods. This class uses a single thread to execute the service; consider {@link AbstractService} * if you would like to manage any threading manually. * * @author Jesse Wilson * @since 1.0 */ @GwtIncompatible @J2ktIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 7.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Callback.kt
* proceed to read the response body with [Response.body]. The response is still live until its * response body is [closed][ResponseBody]. The recipient of the callback may consume the response * body on another thread. * * Note that transport-layer success (receiving a HTTP response code, headers and body) does not
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 1.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ArrayListMultimap.java
@VisibleForTesting transient int expectedValuesPerKey; /** * Creates a new, empty {@code ArrayListMultimap} with the default initial capacities. * * <p>You may also consider the equivalent {@code * MultimapBuilder.hashKeys().arrayListValues().build()}, which provides more control over the * underlying data structure. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 6.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
* limitations under the License. */ package okhttp3.internal.http2.flowcontrol class WindowCounter( val streamId: Int, ) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.3K bytes - Click Count (0)