- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for TRANSMITTER (0.21 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ObjectConnectionBuilder.java
public interface ObjectConnectionBuilder { /** * Creates a transmitter for outgoing messages on the given type. The returned object is thread-safe. * * <p>Method invocations on the transmitter object are dispatched asynchronously to a corresponding handler in the peer. Method invocations are * called on the handler in the same order that they were called on the transmitter object.</p> * * @param type The type
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 2.8K bytes - Viewed (0) -
src/go/doc/comment/testdata/text7.txt
{"TextPrefix": " "} -- input -- Package gob manages streams of gobs - binary values exchanged between an Encoder (transmitter) and a Decoder (receiver). A typical use is transporting arguments and results of remote procedure calls (RPCs) such as those provided by package "net/rpc". The implementation compiles a custom codec for each data type in the stream and is most efficient when a single Encoder is used to transmit a stream of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:31:45 UTC 2022 - 1.1K bytes - Viewed (0) -
src/go/doc/comment/testdata/text3.txt
{"TextWidth": 30} -- input -- Package gob manages streams of gobs - binary values exchanged between an Encoder (transmitter) and a Decoder (receiver). A typical use is transporting arguments and results of remote procedure calls (RPCs) such as those provided by package "net/rpc". The implementation compiles a custom codec for each data type in the stream and is most efficient when a single Encoder is used to transmit a stream of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:31:45 UTC 2022 - 937 bytes - Viewed (0) -
src/go/doc/comment/testdata/text2.txt
{"TextWidth": -1} -- input -- Package gob manages streams of gobs - binary values exchanged between an Encoder (transmitter) and a Decoder (receiver). A typical use is transporting arguments and results of remote procedure calls (RPCs) such as those provided by package "net/rpc". The implementation compiles a custom codec for each data type in the stream and is most efficient when a single Encoder is used to transmit a stream of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:31:41 UTC 2022 - 937 bytes - Viewed (0) -
src/go/doc/comment/testdata/text4.txt
{"TextWidth": 29} -- input -- Package gob manages streams of gobs - binary values exchanged between an Encoder (transmitter) and a Decoder (receiver). A typical use is transporting arguments and results of remote procedure calls (RPCs) such as those provided by package "net/rpc". The implementation compiles a custom codec for each data type in the stream and is most efficient when a single Encoder is used to transmit a stream of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:31:45 UTC 2022 - 937 bytes - Viewed (0) -
src/go/doc/comment/testdata/text5.txt
{"TextWidth": 20} -- input -- Package gob manages streams of gobs - binary values exchanged between an Encoder (transmitter) and a Decoder (receiver). A typical use is transporting arguments and results of remote procedure calls (RPCs) such as those provided by package "net/rpc". The implementation compiles a custom codec for each data type in the stream and is most efficient when a single Encoder is used to transmit a stream of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:31:45 UTC 2022 - 937 bytes - Viewed (0) -
src/go/doc/comment/testdata/text6.txt
-- input -- Package gob manages streams of gobs - binary values exchanged between an Encoder (transmitter) and a Decoder (receiver). A typical use is transporting arguments and results of remote procedure calls (RPCs) such as those provided by package "net/rpc". The implementation compiles a custom codec for each data type in the stream and is most efficient when a single Encoder is used to transmit a stream of values, amortizing the cost of compilation.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:31:45 UTC 2022 - 919 bytes - Viewed (0) -
src/go/doc/comment/testdata/README.md
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 1.3K bytes - Viewed (0) -
src/compress/flate/example_test.go
b := make([]byte, 256) for { // Read the message length. // This is guaranteed to return for every corresponding // Flush and Close on the transmitter side. if _, err := io.ReadFull(zr, b[:1]); err != nil { if err == io.EOF { break // The transmitter closed the stream } log.Fatal(err) } // Read the message content. n := int(b[0])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 12 18:42:35 UTC 2016 - 6.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnectionTest.groovy
e.message == "Cannot add incoming message handler after connection established." cleanup: connection?.stop() connectionBuilder?.stop() } def "cannot create outgoing message transmitter on established connections"() { def connection = new TestConnection() given: connectCompletion.create(_) >> connection when: connectionBuilder.connect()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4K bytes - Viewed (0)