- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,849 for receive (0.44 sec)
-
docs/lambda/README.md
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.7K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* create {@code ListenableFuture} instances depends on how you currently create {@code Future} * instances: * * <ul> * <li>If you receive them from an {@code java.util.concurrent.ExecutorService}, convert that * service to a {@link ListeningExecutorService}, usually by calling {@link * MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* create {@code ListenableFuture} instances depends on how you currently create {@code Future} * instances: * * <ul> * <li>If you receive them from an {@code java.util.concurrent.ExecutorService}, convert that * service to a {@link ListeningExecutorService}, usually by calling {@link * MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
cmd/data-scanner_test.go
} expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) { defer wg.Done() // signal the calling goroutine that the worker is ready tor receive tasks close(readyCh) var expired []ObjectToDelete for t := range taskCh { switch v := t.(type) { case noncurrentVersionsTask: expired = append(expired, v.versions...) case expiryTask:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
doc/go_spec.html
</pre> <h3 id="Receive_operator">Receive operator</h3> <p> For an operand <code>ch</code> of <a href="#Channel_types">channel type</a>, the value of the receive operation <code><-ch</code> is the value received from the channel <code>ch</code>. The channel direction must permit receive operations, and the type of the receive operation is the element type of the channel.
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Dec 02 23:07:19 UTC 2025 - 286.5K bytes - Viewed (1) -
internal/grid/README.md
# MinIO Grid The MinIO Grid is a package that provides two-way communication between servers. It uses a single two-way connection to send and receive messages between servers. It includes built in muxing of concurrent requests as well as congestion handling for streams. Requests can be "Single Payload" or "Streamed". Use the MinIO Grid for: * Small, frequent requests with low latency requirements.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 10 18:57:03 UTC 2025 - 9.4K bytes - Viewed (0) -
docs/recipes.md
Download a file on a worker thread, and get called back when the response is readable. The callback is made after the response headers are ready. Reading the response body may still block. OkHttp doesn't currently offer asynchronous APIs to receive a response body in parts. === ":material-language-kotlin: Kotlin" ```kotlin private val client = OkHttpClient() fun run() { val request = Request.Builder()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 47.8K bytes - Viewed (0) -
docs/en/docs/tutorial/schema-extra-example.md
# Declare Request Example Data { #declare-request-example-data } You can declare examples of the data your app can receive. Here are several ways to do it. ## Extra JSON Schema data in Pydantic models { #extra-json-schema-data-in-pydantic-models } You can declare `examples` for a Pydantic model that will be added to the generated JSON Schema. {* ../../docs_src/schema_extra_example/tutorial001_py310.py hl[13:24] *}Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 20 15:55:38 UTC 2025 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessAsyncNotifyMessage.java
import java.util.List; import jcifs.dcerpc.ndr.NdrBuffer; import jcifs.dcerpc.ndr.NdrException; /** * WitnessAsyncNotify RPC message implementation for MS-SWN specification. * This message is used to receive asynchronous notifications from the witness service. */ public class WitnessAsyncNotifyMessage extends WitnessRpcMessage { // Input parameters for WitnessAsyncNotify private byte[] contextHandle;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 16.4K bytes - Viewed (0) -
README.md
- GitHub Releases: https://github.com/minio/minio/releases - Direct downloads: https://dl.min.io/server/minio/release/ **These legacy binaries will not receive updates.** We strongly recommend using source builds for access to the latest features, bug fixes, and security updates. ## Install from Source
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Dec 03 08:13:11 UTC 2025 - 9K bytes - Viewed (0)