- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 277 for flow (0.02 sec)
-
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/ActiveProjectArtifact.java
/** * Wraps an active project instance to be able to receive updates from its artifact without affecting the original * attributes of this artifact. * * TODO I think this exposes a design flaw in that the immutable and mutable parts of an artifact are in one class and * should be split. ie scope, file, etc depend on the context of use, whereas everything else is immutable. */ @Deprecated
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 9.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/EnumMultiset.java
* * @author Jared Levy * @since 2.0 */ @GwtCompatible @J2ktIncompatible @SuppressWarnings("EnumOrdinal") // This is one of the low-level utilities where it's suitable. public final class EnumMultiset<E extends Enum<E>> extends AbstractMultiset<E> implements Serializable { /** Creates an empty {@code EnumMultiset}. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 9.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java
* process it; all should produce the same answer, the only difference should be the number of * process()/processRemaining() invocations, due to alignment. */ @AndroidIncompatible // slow. TODO(cpovirk): Maybe just reduce iterations under Android. public void testExhaustive() throws Exception { Random random = new Random(0); // will iteratively make more debuggable, each time it breaks
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.5K bytes - Viewed (0) -
cmd/peer-rest-client.go
} st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error { select { case traceCh <- b: default: // Do not block on slow receivers. // Just recycle the buffer. grid.PutByteBuffer(b) } return nil }) } func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java
} @GwtIncompatible // slow (~40s) public void testIterator_oneElement() { new IteratorTester<String>( 5, UNMODIFIABLE, singleton("a"), IteratorTester.KnownOrder.KNOWN_ORDER) { @Override protected Iterator<String> newTargetIterator() { return of("a").iterator(); } }.test(); } @GwtIncompatible // slow (~30s) public void testIterator_general() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.20.md
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Jan 19 21:05:45 UTC 2022 - 409K bytes - Viewed (0) -
android/guava/src/com/google/common/xml/XmlEscapers.java
* replaces the allowed ASCII whitespace characters with themselves and to set the minimum safe * character to 0x20. However this would slow down the escaping of simple strings that contain * \t, \n, or \r. */ for (char c = MIN_ASCII_CONTROL_CHAR; c <= MAX_ASCII_CONTROL_CHAR; c++) { if (c != '\t' && c != '\n' && c != '\r') {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jun 20 17:15:33 UTC 2025 - 6.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java
} } @Test @DisplayName("Should evict oldest leases when max limit reached") void testMaxLeaseEviction() throws InterruptedException { // Create a context with low max lease limit Configuration limitedConfig = mock(Configuration.class); CIFSContext limitedContext = mock(CIFSContext.class); when(limitedContext.getConfig()).thenReturn(limitedConfig);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 00:16:17 UTC 2025 - 13.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
) client = clientTestRule .newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks. .dns { dnsResults } .fastFallback(true) .build() url = serverIpv4 .url("/") .newBuilder() .host("localhost") .build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 10.4K bytes - Viewed (0) -
lib/wasm/wasm_exec.js
} const setInt32 = (addr, v) => { this.mem.setUint32(addr + 0, v, true); } const getInt64 = (addr) => { const low = this.mem.getUint32(addr + 0, true); const high = this.mem.getInt32(addr + 4, true); return low + high * 4294967296; } const loadValue = (addr) => { const f = this.mem.getFloat64(addr, true); if (f === 0) { return undefined; }
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Sun Dec 08 15:34:47 UTC 2024 - 16.6K bytes - Viewed (0)