- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for asynchronously (0.2 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
final 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) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
final 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) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* } catch (TimeoutException timeout) { * // stopping timed out * } * } * }); * manager.startAsync(); // start all the services asynchronously * } * } * }</pre> * * <p>This class uses the ServiceManager's methods to start all of its services, to respond to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.h
// re-use a thread. std::vector<std::unique_ptr<DeviceThread>> device_threads_; // A cancellation manager to use if the caller does not provide one. When ops // are executed asynchronously this must outlive the queued op, so it can't be // function-local to Execute. mutable std::unique_ptr<CancellationManager> default_cancellation_manager_; };
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Apr 25 15:21:13 GMT 2023 - 12.9K bytes - Viewed (0) -
okhttp/src/main/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
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
common-protos/k8s.io/api/certificates/v1/generated.proto
option go_package = "k8s.io/api/certificates/v1"; // CertificateSigningRequest objects provide a mechanism to obtain x509 certificates // by submitting a certificate signing request, and having it asynchronously approved and issued. // // Kubelets use this API to obtain: // 1. client certificates to authenticate to kube-apiserver (with the "kubernetes.io/kube-apiserver-client-kubelet" signerName).
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 11.6K 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/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) -
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)