- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 204 for Flow (0.28 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) } @Tag("Slow") @Test fun successfulExpectContinuePermitsConnectionReuseWithHttp2() { enableProtocol(Protocol.HTTP_2) successfulExpectContinuePermitsConnectionReuse() } @Tag("Slow") @Test fun unsuccessfulExpectContinuePreventsConnectionReuse() { server.enqueue(MockResponse())
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0) -
guava/src/com/google/common/collect/CompactHashing.java
/** Use high bits of metadata for modification count. */ static final int MODIFICATION_COUNT_INCREMENT = 1 << HASH_TABLE_BITS_MAX_BITS; /** Bitmask that selects the low bits of metadata to get hashTableBits. */ static final int HASH_TABLE_BITS_MASK = (1 << HASH_TABLE_BITS_MAX_BITS) - 1; /** Maximum size of a compact hash-based collection (2^30 - 1 because 0 is UNSET). */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 7.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* problems can exist with methods like FutureTask.done(), not to mention slow calls to * Thread.interrupt() (as discussed in InterruptibleTask). At the end of the day, it's * unlikely that cancel() will be slow, so we can probably get away with calling it while * holding a lock. Still, it would be nice to avoid somehow. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
/** True if this connect was canceled; typically because it lost a race. */ @Volatile private var canceled = false // These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: JavaNetSocket? = null /** * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket] * itself if this connection does not use SSL.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 19.3K bytes - Click Count (2) -
android/guava-tests/test/com/google/common/collect/ImmutableRangeSetTest.java
assertThrows( UnsupportedOperationException.class, () -> rangeSet.removeAll(ImmutableRangeSet.of(Range.closed(6, 8)))); } @AndroidIncompatible // slow public void testExhaustive() { ImmutableSet<Range<Integer>> ranges = ImmutableSet.of( Range.<Integer>all(), Range.<Integer>closedOpen(3, 5), Range.singleton(1),Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 25 16:19:30 GMT 2025 - 21.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/IterablesTest.java
List<String> list = ImmutableList.of("a", "b"); Iterator<String> iterator = skip(list, 2).iterator(); assertThrows(UnsupportedOperationException.class, () -> iterator.remove()); } @GwtIncompatible // slow (~35s) public void testSkip_iterator() { new IteratorTester<Integer>( 5, MODIFIABLE, newArrayList(2, 3), IteratorTester.KnownOrder.KNOWN_ORDER) { @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 47.5K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
try { constructor = type.getConstructor(); } catch (NoSuchMethodException e) { return arbitraryConstantInstanceOrNull(type); } constructor.setAccessible(true); // accessibility check is too slow try { return constructor.newInstance(); } catch (InstantiationException | IllegalAccessException impossible) { throw new AssertionError(impossible); } catch (InvocationTargetException e) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 21.4K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/SortedMultisetTestSuiteBuilder.java
.withFeatures(features) .suppressing(parentBuilder.getSuppressedTests()) .createTestSuite(); } /** * Returns an array of four bogus elements that will always be too high or too low for the * display. This includes two values for each extreme. * * <p>This method (dangerously) assume that the strings {@code "!! a"} and {@code "~~ z"} will
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 11.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension @Flaky @Tag("Slow") class WebSocketHttpTest { // Flaky https://github.com/square/okhttp/issues/4515 // Flaky https://github.com/square/okhttp/issues/4953 @RegisterExtension var clientTestRule = configureClientTestRule()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/primitives/DoublesTest.java
} } } } } } } } @AndroidIncompatible // slow @GwtIncompatible // Doubles.tryParse public void testTryParseAllCodePoints() { // Exercise non-ASCII digit test cases and the like. char[] tmp = new char[2];Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 01:43:32 GMT 2026 - 30.9K bytes - Click Count (0)