- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 4,005 for Receive (0.24 sec)
-
test/fixedbugs/bug448.dir/pkg2.go
// Copyright 2012 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Issue 3843: inlining bug due to wrong receive operator precedence. package pkg2 import "./pkg1" func F() { pkg1.Do()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 287 bytes - Viewed (0) -
test/typeparam/chansimp.dir/main.go
} } func TestRanger() { s, r := a.Ranger[int]() ctx := context.Background() go func() { // Receive one value then exit. v, ok := r.Next(ctx) if !ok { panic(fmt.Sprintf("did not receive any values")) } else if v != 1 { panic(fmt.Sprintf("received %d, want 1", v)) } }() c1 := make(chan bool) c2 := make(chan bool) go func() { defer close(c2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 24 02:14:15 UTC 2022 - 3.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/sockcmsg_linux.go
h.Type = SCM_CREDENTIALS h.SetLen(CmsgLen(SizeofUcred)) *(*Ucred)(h.data(0)) = *ucred return b } // ParseUnixCredentials decodes a socket control message that contains // credentials in a Ucred structure. To receive such a message, the // SO_PASSCRED option must be enabled on the socket. func ParseUnixCredentials(m *SocketControlMessage) (*Ucred, error) { if m.Header.Level != SOL_SOCKET { return nil, EINVAL }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 09 20:10:21 UTC 2021 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/Message.java
/** * Serialize the <code>message</code> onto the provided <code>outputStream</code>, replacing all {@link Throwable}s in the object graph with a placeholder object that can be read back by {@link * #receive(java.io.InputStream, ClassLoader)}. * * @param message object to serialize * @param outputSteam stream to serialize onto */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 2.2K bytes - Viewed (0) -
docs/de/docs/how-to/custom-request-and-route.md
Ein `Request` hat auch ein `request.receive`, welches eine Funktion ist, die den Hauptteil des Requests empfängt. Das `scope`-`dict` und die `receive`-Funktion sind beide Teil der ASGI-Spezifikation. Und diese beiden Dinge, `scope` und `receive`, werden benötigt, um eine neue `Request`-Instanz zu erstellen.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 30 18:18:23 UTC 2024 - 5.2K bytes - Viewed (0) -
manifests/helm-profiles/openshift-ambient.yaml
logLevel: info provider: "multus" pilot: cni: enabled: true provider: "multus" variant: distroless env: PILOT_ENABLE_AMBIENT: "true" # Allow sidecars/ingress to send/receive HBONE. This is required for interop. PILOT_ENABLE_SENDING_HBONE: "true" PILOT_ENABLE_SIDECAR_LISTENING_HBONE: "true" platform: openshift variant: distroless seLinuxOptions:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 30 20:24:06 UTC 2024 - 664 bytes - Viewed (0) -
src/net/textproto/pipeline.go
// the request with the given id. func (p *Pipeline) StartRequest(id uint) { p.request.Start(id) } // EndRequest notifies p that the request with the given id has been sent // (or, if this is a server, received). func (p *Pipeline) EndRequest(id uint) { p.request.End(id) } // StartResponse blocks until it is time to receive (or, if this is a server, send)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 08 16:19:51 UTC 2020 - 3K bytes - Viewed (0) -
tests/integration/helm/install_test.go
`with binding 'stable-channel-default-policy-binding.istio.io' denied request` err := t.ConfigIstio().Eval("default", nil, sampleEnvoyFilter).Apply() if err == nil { t.Errorf("Did not receive an error while applying sample EnvoyFilter with stable admission policy") } else { msg := fmt.Sprintf(expectedErrorPrefix, "envoyfilters.networking.istio.io") if !strings.Contains(err.Error(), msg) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
supportsStreamClose := protocolSupportsStreamClose(conn.selectedProtocol) for { conn.resetTimeout() var data []byte if err := websocket.Message.Receive(ws, &data); err != nil { if err != io.EOF { klog.Errorf("Error on socket receive: %v", err) } break } if len(data) == 0 { continue } if supportsStreamClose && data[0] == remotecommand.StreamClose { if len(data) != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/scheduler/framework/parallelize/error_channel.go
limitations under the License. */ package parallelize import "context" // ErrorChannel supports non-blocking send and receive operation to capture error. // A maximum of one error is kept in the channel and the rest of the errors sent // are ignored, unless the existing error is received and the channel becomes empty // again. type ErrorChannel struct { errCh chan error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0)