Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 97 for synchronously (0.07 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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 response
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 19 07:04:54 GMT 2026
    - 7.3K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top