- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 97 for asynchronously (0.21 sec)
-
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
import org.checkerframework.checker.nullness.qual.Nullable; /** * A step in a pipeline of an asynchronous computation. When the last step in the computation is * complete, some objects captured during the computation are closed. * * <p>A pipeline of {@code ClosingFuture}s is a tree of steps. Each step represents either an * asynchronously-computed intermediate value, or else an exception that indicates the failure or
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
docs/bucket/replication/README.md
### Sync/Async Replication By default, replication is completed asynchronously. If synchronous replication is desired, set the --sync flag while adding a remote replication target using the `mc admin bucket remote add` command. For mc releases on or after `RELEASE.2022-12-24T15-21-38Z`, the
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 24 23:46:33 GMT 2023 - 18.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
throw InterruptedIOException() } } /** * The Okio timeout watchdog will call [timedOut] if the timeout is reached. In that case we close * the stream (asynchronously) which will notify the waiting thread. */ internal inner class StreamTimeout : AsyncTimeout() { override fun timedOut() { closeLater(ErrorCode.CANCEL) connection.sendDegradedPingLater()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
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` Asynchronously streams a file as the response. Takes a different set of arguments to instantiate than the other response types: * `path` - The filepath to the file to stream.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 11.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
.build() val responseB = client.newCall(requestB).execute() assertThat(responseB.body.string()).isEqualTo("b") } /** Make sure interceptors can interact with the OkHttp client asynchronously. */ @Test fun interceptorMakesAnUnrelatedAsyncRequest() { server.enqueue(MockResponse.Builder().body("a").build()) // Fetched by interceptor.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
return (FluentFuture<V>) Futures.withTimeout(this, timeout, unit, scheduledExecutor); } /** * Returns a new {@code Future} whose result is asynchronously derived from the result of this * {@code Future}. If the input {@code Future} fails, the returned {@code Future} fails with the * same exception (and the function is not invoked). *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
okhttp/src/main/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 { return send(text.encodeUtf8(), OPCODE_TEXT) } override fun send(bytes: ByteString): Boolean {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
docs/en/docs/async.md
* **Asynchronous Code** * **`async` and `await`** * **Coroutines** ## Asynchronous Code Asynchronous code just means that the language 💬 has a way to tell the computer / program 🤖 that at some point in the code, it 🤖 will have to wait for *something else* to finish somewhere else. Let's say that *something else* is called "slow-file" 📝. So, during that time, the computer can go and do some other work, while "slow-file" 📝 finishes.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_test.cc
ExpectScalarEq<float>(result_components[1].get(), 3.); } TEST(PARALLEL_DEVICE, TestCollectiveSync) { TestCollective(/*async=*/false); } // Note that ops on the parallel device currently don't execute // asynchronously. The test is just that we don't get deadlocks. TEST(PARALLEL_DEVICE, TestCollectiveAsync) { TestCollective(/*async=*/true); } void RegisterCollectiveMulFunction(TFE_Context* context,
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 08 23:47:35 GMT 2021 - 29.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
internal var nextStreamId = if (builder.client) 3 else 2 private var isShutdown = false /** For scheduling everything asynchronous. */ private val taskRunner = builder.taskRunner /** Asynchronously writes frames to the outgoing socket. */ private val writerQueue = taskRunner.newQueue() /** Ensures push promise callbacks events are sent in order per stream. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0)