- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 513 for completes (0.53 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
/** * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the * future to finish, and when it completes, run the listeners. This implementation will wait on * the source future indefinitely, so if the source future never completes, the adapter will never * complete either. * * <p>If the delegate future is interrupted or throws an unexpected unchecked exception, the * listeners will not be invoked.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* * <p>The returned {@link Future} is completed when the pipeline's computation completes, or when * the pipeline is cancelled. * * <p>All objects the pipeline has captured for closing will begin to be closed asynchronously * <b>after</b> the returned {@code Future} is done: the future completes before closing starts, * rather than once it has finished. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 101.7K 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) -
cycle_suppress_list.txt
NAMESPACE com.google.common.net NAMESPACE com.google.common.testing # Allow our dependencies for now. NAMESPACE junit.framework NAMESPACE org.junit # ***** REAL CYCLES ***** # Cycle exists until future completes FIELD com.google.common.util.concurrent.AbstractFuture.Listener.executor com.google.common.util.concurrent.ExecutionSequencer.TaskNonReentrantExecutor # ***** FALSE POSITIVES *****
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 24 01:59:49 GMT 2025 - 3.2K 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)