Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 120 for asynchronous (0.06 sec)

  1. 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.
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun Apr 27 06:05:16 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    		// whether to replicate as the target could be temporarily down
    		opts.TargetArn = tgtArn
    		replicate := cfg.Replicate(opts)
    		var synchronous bool
    		if tgt != nil {
    			synchronous = tgt.replicateSync
    		}
    		dsc.Set(newReplicateTargetDecision(tgtArn, replicate, synchronous))
    	}
    	return dsc
    }
    
    // Standard headers that needs to be extracted from User metadata.
    var standardHeaders = []string{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  3. docs/fr/docs/async.md

    ```Python hl_lines="1"
    async def get_burgers(number: int):
        # Opérations asynchrones pour créer les burgers
        return burgers
    ```
    
    ...et non `def` :
    
    ```Python hl_lines="2"
    # Ceci n'est pas asynchrone
    def get_sequential_burgers(number: int):
        # Opérations asynchrones pour créer les burgers
        return burgers
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     *
     * All event methods must execute fast, without external locking, cannot throw exceptions, attempt
     * to mutate the event parameters, or be re-entrant back into the client. Any IO - writing to files
     * or network should be done asynchronously.
     */
    abstract class EventListener {
      /**
       * Invoked as soon as a call is enqueued or executed by a client. In case of thread or stream
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

            }
            saveInfo(messages -> messages.addSuccessBulkProcessStarted(GLOBAL));
            return redirect(getClass()); // no-op
        }
    
        /**
         * Import the file asynchronously.
         * @param fileName The file name.
         * @param tempFile The temporary file.
         */
        protected void asyncImport(final String fileName, final File tempFile) {
            final int fileType;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 29.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/util/transport/Transport.java

                if (Thread.currentThread() == this.thread) {
                    // we are in the transport thread, ie. on idle disconnecting
                    // this is synchronous operation
                    // This does not handle compound requests
                    synchronized (this.inLock) {
                        final Long peekKey = peekKey();
                        if (peekKey == firstKey) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  7. docs/de/docs/async.md

    werden muss und nicht auf den genauen Moment warten muss, in dem die Aufgabe beendet ist, ohne dabei etwas zu tun, um schließlich das Ergebnis der Aufgabe zu übernehmen und die Arbeit fortsetzen zu können.
    
    Da es sich stattdessen um ein „asynchrones“ System handelt, kann die Aufgabe nach Abschluss ein wenig (einige Mikrosekunden) in der Schlange warten, bis das System / Programm seine anderen Dinge erledigt hat und zurückkommt, um die Ergebnisse entgegenzunehmen und mit ihnen weiterzuarbeiten....
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

                this.windowSize = windowSize;
            }
            load();
        }
    
        /**
         * Updates the processor configuration by reloading available searchers.
         * This method executes the load operation asynchronously in a separate thread.
         */
        public void update() {
            CommonPoolUtil.execute(this::load);
        }
    
        /**
         * Loads the available searcher names from system properties.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  9. docs/en/docs/advanced/custom-response.md

    /// tip
    
    Notice that here as we are using standard `open()` that doesn't support `async` and `await`, we declare the path operation with normal `def`.
    
    ///
    
    ### `FileResponse` { #fileresponse }
    
    Asynchronously streams a file as the response.
    
    Takes a different set of arguments to instantiate than the other response types:
    
    * `path` - The file path to the file to stream.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          receivedCloseCode = code
          receivedCloseReason = reason
        }
    
        listener.onClosing(this, code, reason)
      }
    
      // Writer methods to enqueue frames. They'll be sent asynchronously by the writer thread.
    
      override fun send(text: String): Boolean = send(text.encodeUtf8(), OPCODE_TEXT)
    
      override fun send(bytes: ByteString): Boolean = send(bytes, OPCODE_BINARY)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
Back to top