- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 501 for completes (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// before the cancelled future completes, it will synchronously complete both the newFuture // from the cancelled operation and its own. This can cause one runnable to queue two tasks, // breaking the invariant this method relies on to iteratively run the next task after the // previous one completes. if (get() == RunningState.CANCELLED) { delegate = null;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/persistent/HandleReconnector.java
} /** * Attempt to reconnect a handle * @param path the file path * @param cause the original exception that triggered reconnection * @return a future that completes with the reconnected handle info or fails */ public CompletableFuture<HandleInfo> reconnectHandle(String path, Exception cause) { HandleInfo info = handleManager.getHandleForReconnect(path);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 04:51:33 GMT 2025 - 8.5K bytes - Click Count (1) -
android/guava/src/com/google/common/cache/LoadingCache.java
/** * Returns the value associated with {@code key} in this cache, first loading that value if * necessary. No observable state associated with this cache is modified until loading completes. * * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note thatCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHookTest.java
// Should not throw any exception during normal execution curtainFinallyHook.hook(assistantDirector); // Verify that the method completes without errors assertTrue(true); // Method completed successfully } // Test hook method when MultiThreadedHttpConnectionManager class is not available @Test public void test_hook_classNotFound() {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 8.7K bytes - Click Count (0) -
guava/src/com/google/common/cache/LoadingCache.java
/** * Returns the value associated with {@code key} in this cache, first loading that value if * necessary. No observable state associated with this cache is modified until loading completes. * * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note thatCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbSessionInternalTest.java
when(session.getTransport()).thenReturn(transport); assertSame(transport, session.getTransport()); verify(session).getTransport(); } // Happy path: connect to logon share completes without exception @Test @DisplayName("treeConnectLogon performs call without exception") void treeConnectLogon_happy() throws SmbException { // doNothing by default
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 6.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
} try { super.close() complete(null) } catch (e: IOException) { throw complete(e)!! } } /** If [e] is non-null, this will return a non-null value. */ private fun complete(e: IOException?): IOException? { if (completed) return e completed = true return bodyComplete( bytesRead = bytesReceived,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 10.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt
.build(), ) call1.execute().use { response -> response.body.string() } listener.shouldClose = true // Large headers are a likely reason the servers would cut off the connection before it completes sending // request headers. // 431 "Request Header Fields Too Large" val largeHeaders = Headers .Builder() .apply { repeat(32) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/chat/ChatPhaseCallback.java
default void onPhaseStart(final String phase, final String message, final String keywords) { onPhaseStart(phase, message); } /** * Called when a processing phase completes. * * @param phase the phase name that completed */ void onPhaseComplete(String phase); /** * Called when a chunk of the response is available during streaming. * * @param content the content chunk
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jan 15 12:32:04 GMT 2026 - 3.3K bytes - Click Count (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
// error if the server message is invalid. Calling Step after a conversation // completes is also an error. func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) { response, err = x.ClientConversation.Step(challenge) return response, err } // Done returns true if the conversation is completed or has errored. func (x *XDGSCRAMClient) Done() bool { return x.ClientConversation.Done()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.3K bytes - Click Count (0)