- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 327 for flow (0.02 sec)
-
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()) {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 9.4K bytes - Viewed (0) -
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 Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 9.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
* this address. * * If [planToReplace] is non-null, this will swap it for a pooled connection if that pooled * connection uses HTTP/2. That results in fewer sockets overall and thus fewer TCP slow starts. */ internal fun planReusePooledConnection( planToReplace: ConnectPlan? = null, routes: List<Route>? = null, ): ReusePlan? { val result =
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 12K bytes - Viewed (0) -
internal/event/targetlist.go
list.eventsSkipped.Add(int64(len(list.queue))) return default: list.eventsSkipped.Add(1) err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend) for id := range targetIDset { reqInfo := &logger.ReqInfo{} reqInfo.AppendTags("targetID", id.String())
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.2K bytes - Viewed (0) -
internal/config/api/api.go
} cfg.ListQuorum = listQuorum replicationPriority := env.Get(EnvAPIReplicationPriority, kvs.GetWithDefault(apiReplicationPriority, DefaultKVS)) switch replicationPriority { case "slow", "fast", "auto": default: return cfg, fmt.Errorf("invalid value %v for replication_priority", replicationPriority) } cfg.ReplicationPriority = replicationPriority
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.5K bytes - Viewed (1) -
CHANGELOG/CHANGELOG-1.20.md
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Jan 19 21:05:45 UTC 2022 - 409K bytes - Viewed (0) -
architecture/standards/0008-use-nullaway.md
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Thu Dec 11 10:24:40 UTC 2025 - 4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/AndXServerMessageBlockTest.java
}; byte[] buffer = new byte[1024]; // Setup buffer after header buffer[33] = 4; // wordCount buffer[34] = (byte) 0xFF; // andxCommand buffer[36] = 0; // andxOffset low buffer[37] = 0; // andxOffset high SMBUtil.writeInt2(20, buffer, 42); // byteCount int length = testBlock.decode(buffer, 0); assertTrue(length > 0);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.4K bytes - Viewed (0) -
doc/asm.html
specific to each architecture. The sections below list these. </p> <p> One detail evident in the examples from the previous sections is that data in the instructions flows from left to right: <code>MOVQ</code> <code>$0,</code> <code>CX</code> clears <code>CX</code>. This rule applies even on architectures where the conventional notation uses the opposite direction. </p> <p>
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Nov 14 19:09:46 UTC 2025 - 36.5K bytes - Viewed (0) -
internal/etag/reader.go
// nil as ETag. // // Wrap provides an adapter for io.Reader implementations // that don't implement the Tagger interface. // It is mainly used to provide a high-level io.Reader // access to the ETag computed by a low-level io.Reader: // // content := etag.NewReader(r.Body, nil) // // compressedContent := Compress(content) // encryptedContent := Encrypt(compressedContent) // // // Now, we need an io.Reader that can access
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 4.8K bytes - Viewed (0)