- Sort Score
- Result 10 results
- Languages All
Results 11 - 14 of 14 for TRANSMITTER (0.13 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
} @Override public <T> T addOutgoing(Class<T> type) { if (connection != null) { throw new GradleException("Cannot add outgoing message transmitter after connection established."); } methodParamClassLoaders.add(type.getClassLoader());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
src/encoding/gob/doc.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. /* 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 [net/rpc].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 20:22:45 UTC 2024 - 17.1K bytes - Viewed (0) -
src/os/timeout_test.go
if err := w.SetWriteDeadline(deadline); err != nil { t.Fatalf("SetWriteDeadline(%v): %v", deadline, err) } var n int64 var err error for { var dn int dn, err = w.Write([]byte("TIMEOUT TRANSMITTER")) n += int64(dn) if err != nil { break } } t1 := time.Now() // Inv: err != nil if !isDeadlineExceeded(err) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 17.1K bytes - Viewed (0) -
src/net/timeout_test.go
if err := c.SetWriteDeadline(deadline); err != nil { t.Fatalf("SetWriteDeadline(%v): %v", deadline, err) } var n int64 var err error for { var dn int dn, err = c.Write([]byte("TIMEOUT TRANSMITTER")) n += int64(dn) if err != nil { break } } t1 := time.Now() // Inv: err != nil if !err.(Error).Timeout() { t.Fatalf("Write did not return (any, timeout): (%d, %v)", n, err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0)