- Sort Score
- Num 10 results
- Language All
Results 51 - 60 of 97 for synchronously (0.07 seconds)
-
src/main/java/jcifs/internal/smb2/Smb2CancelRequest.java
* The configuration to use * @param mid * The message ID of the request to cancel * @param asyncId * The async ID for asynchronous operations (0 for synchronous) */ public Smb2CancelRequest(final Configuration config, final long mid, final long asyncId) { super(config, SMB2_CANCEL); setMid(mid); setAsyncId(asyncId); if (asyncId != 0) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 4.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
NoOpService service1 = new NoOpService(); // This service will start service1 when addListener is called. This simulates service1 being // started asynchronously. Service service2 = new Service() { final NoOpService delegate = new NoOpService(); @Override public final void addListener(Listener listener, Executor executor) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
// it defaults to defaultTTL. // // This function defines an onEvicted callback that is invoked when a cache entry is evicted. // The callback ensures that if the evicted value (v) is not nil, its Close method is called asynchronously // to release associated resources. // // Returns: // - A Store instance implemented by lruStore, which internally uses an LRU cache with the specified size, // eviction callback, and TTL.
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 6.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/LlmClient.java
*/ RelevanceEvaluationResult evaluateResults(String userMessage, String query, List<Map<String, Object>> searchResults); /** * Generates an answer using document content (synchronous version for non-enhanced flow). * * @param userMessage the user's message * @param documents the documents with content * @param history the conversation history * @return the chat responseCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 19 07:04:54 GMT 2026 - 7.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
NoOpService service1 = new NoOpService(); // This service will start service1 when addListener is called. This simulates service1 being // started asynchronously. Service service2 = new Service() { final NoOpService delegate = new NoOpService(); @Override public final void addListener(Listener listener, Executor executor) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/session/Smb2SessionSetupResponseTest.java
return new Smb2SessionSetupResponse(cfg); } /** * Build a minimal SMB2 header for a response at the given offset. * The header is prepared as a synchronous response with server-to-redirector flag. */ private void buildHeader(byte[] buf, int start, int status, int command, long sessionId) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/base/login/FessLoginAssist.java
return OptionalThing.empty(); } /** * Saves the login history for the given user. * This operation is performed asynchronously. * * @param user the user entity * @param userBean the user bean * @param option the login specified option */ @Override
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 12.1K bytes - Click Count (0) -
docs/config/README.md
root_access (boolean) turn 'off' root credential access for all API calls including s3, admin operations (default: 'on') sync_events (boolean) set to enable synchronous bucket notifications (default: 'off') object_max_versions (number) set max allowed number of versions per object (default: '9223372036854775807') ``` or environment variables ```
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.1K bytes - Click Count (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
* when responses are of an unexpected type or cannot be decoded. * * Other exception types cancel the current call: * * * For synchronous calls made with [Call.execute], the exception is propagated to the caller. * * * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 8.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* } catch (TimeoutException timeout) { * // stopping timed out * } * } * }); * manager.startAsync(); // start all the services asynchronously * } * } * } * * <p>This class uses the ServiceManager's methods to start all of its services, to respond to
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 33.2K bytes - Click Count (1)