- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 120 for asynchronous (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)