- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 241 for Flow (0.03 seconds)
-
guava-tests/test/com/google/common/collect/ImmutableRangeMapTest.java
} ImmutableRangeMap<Integer, Integer> map = builder.build(); for (int i = 0; i < 100; i++) { assertEquals(Integer.valueOf(i), map.get(i)); } } @AndroidIncompatible // slow public void testAsMapOfRanges() { for (Range<Integer> range1 : RANGES) { for (Range<Integer> range2 : RANGES) { if (!range1.isConnected(range2) || range1.intersection(range2).isEmpty()) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 9.4K bytes - Click Count (0) -
architecture/standards/0008-use-nullaway.md
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Mar 05 12:39:41 GMT 2026 - 4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
* Each response body is backed by a limited resource like a socket (live network responses) or * an open file (for cached responses). Failing to close the response body will leak resources and * may ultimately cause the application to slow down or crash. * * Both this class and [Response] implement [Closeable]. Closing a response simply * closes its response body. If you invoke [Call.execute] or implement [Callback.onResponse] you
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue May 27 14:51:25 GMT 2025 - 11.6K bytes - Click Count (0) -
android/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/AbstractFuture.java
* cancelled without a call to {@code cancel}, such as by calling {@code * setFuture(cancelledFuture)}. * * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or * acquire other locks, risking deadlocks. */ @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { @RetainedLocalRef Object localValue = value();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/ContiguousSetTest.java
assertTrue(enormous instanceof RegularContiguousSet); // We can't use reserializeAndAssert because it calls hashCode, which is enormously slow. ContiguousSet<Integer> enormousReserialized = reserialize(enormous); assertEquals(enormous, enormousReserialized); } private static final DiscreteDomain<Integer> UNBOUNDED_THROWING_DOMAIN =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 08 18:10:02 GMT 2026 - 19.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/CompactLinkedHashMap.java
} private static final int ENDPOINT = -2; /** * Contains the link pointers corresponding with the entries, in the range of [0, size()). The * high 32 bits of each long is the "prev" pointer, whereas the low 32 bits is the "succ" pointer * (pointing to the next entry in the linked list). The pointers in [size(), entries.length) are * all "null" (UNSET). *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Aug 06 14:59:07 GMT 2025 - 8.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
) client = clientTestRule .newClientBuilder() .eventListenerFactory(clientTestRule.wrap(eventRecorder)) .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks. .dns { dnsResults } .fastFallback(true) .build() url = serverIpv4 .url("/") .newBuilder() .host("localhost") .build()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.6K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/LongAdder.java
* * <p>This class is usually preferable to {@link AtomicLong} when multiple threads update a common * sum that is used for purposes such as collecting statistics, not for fine-grained synchronization * control. Under low update contention, the two classes have similar characteristics. But under * high contention, expected throughput of this class is significantly higher, at the expense of * higher space consumption. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 20 13:05:10 GMT 2025 - 5.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/hash/HashingTest.java
HashTestUtils.assertInvariants(Hashing.fingerprint2011()); assertThat(Hashing.fingerprint2011().toString()).isEqualTo("Hashing.fingerprint2011()"); } @AndroidIncompatible // slow TODO(cpovirk): Maybe just reduce iterations under Android. public void testGoodFastHash() { for (int i = 1; i < 200; i += 17) { HashFunction hasher = Hashing.goodFastHash(i);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 26.7K bytes - Click Count (2)