- Sort Score
- Num 10 results
- Language All
Results 1511 - 1520 of 1,709 for Where (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
// TODO(cpovirk): consider using the logger associated with listener.getClass(). private static final LazyLogger logger = new LazyLogger(ListenerCallQueue.class); // TODO(chrisn): promote AppendOnlyCollection for use here. private final List<PerListenerQueue<L>> listeners = Collections.synchronizedList(new ArrayList<PerListenerQueue<L>>()); /** Method reference-compatible listener event. */ interface Event<L> {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 8.1K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFileHandleImpl.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 9.4K bytes - Click Count (1) -
src/test/java/jcifs/smb/SpnegoContextTest.java
// Act: len==0 triggers initial token construction byte[] out = ctx.initSecContext(null, 0, 0); // Assert: returns a SPNEGO token (opaque here but non-null/non-empty) assertNotNull(out); assertTrue(out.length > 0); // Verify interactions: flags and an empty optimistic token are used verify(this.mechContext, times(1)).getFlags();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.3K bytes - Click Count (0) -
android/guava/src/com/google/common/graph/DirectedGraphConnections.java
PredAndSucc(Object successorValue) { this.successorValue = successorValue; } } /** * A value class representing single connection between the origin node and another node. * * <p>There can be two types of connections (predecessor and successor), which is represented by * the two implementations. */ private abstract static class NodeConnection<N> { final N node; NodeConnection(N node) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 17.8K bytes - Click Count (0) -
guava/src/com/google/common/collect/CollectCollectors.java
Function<? super T, ? extends V> valueFunction) { checkNotNull(comparator); checkNotNull(keyFunction); checkNotNull(valueFunction); /* * We will always fail if there are duplicate keys, and the keys are always sorted by * the Comparator, so the entries can come in an arbitrary order -- so we report UNORDERED. */ return Collector.of(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 16.6K bytes - Click Count (0) -
cmd/bucket-stats.go
} func newBucketReplicationStats() *BucketReplicationStats { return &BucketReplicationStats{ Stats: make(map[string]*BucketReplicationStat), } } // Empty returns true if there are no target stats func (brs *BucketReplicationStats) Empty() bool { return len(brs.Stats) == 0 && brs.ReplicaSize == 0 } // Clone creates a new BucketReplicationStats copy
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.5K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
ChecksumObserver observer = checksums.get(extension); sums.put(extension, observer.getActualChecksum()); } // We do this in here so we can checksum the artifact metadata too, otherwise it could be metadata itself for (String extension : checksums.keySet()) { // TODO shouldn't need a file intermediary - improve wagon to take a stream
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 29.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
* * `Response.body().source().close()` * * `Response.body().charStream().close()` * * `Response.body().byteStream().close()` * * `Response.body().bytes()` * * `Response.body().string()` * * There is no benefit to invoking multiple `close()` methods for the same response body. * * For synchronous calls, the easiest way to make sure a response body is closed is with a `try`
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) -
docs/fr/docs/tutorial/handling-errors.md
Mais elle sera gérée par `unicorn_exception_handler`. Ainsi, vous recevrez une erreur propre, avec un code d'état HTTP `418` et un contenu JSON : ```JSON {"message": "Oops! yolo did something. There goes a rainbow..."} ``` /// note | Détails techniques Vous pourriez aussi utiliser `from starlette.requests import Request` et `from starlette.responses import JSONResponse`.Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 10K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
connectionPool.evictAll() if (connectionPool.connectionCount() > 0) { // Minimise test flakiness due to possible race conditions with connections closing. // Some number of tests will report here, but not fail due to this delay. println("Delaying to avoid flakes") Thread.sleep(500L) println("After delay: " + connectionPool.connectionCount()) } connectionPool.evictAll()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.8K bytes - Click Count (0)