- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 223 for recvs (0.1 sec)
-
test/closedchan.go
if x := c.Recv(); x != 1 { println("testasync1: Recv did not get 1:", x, c.Impl()) failed = true } test1(c) } func testasync2(c Chan) { // should be able to get the last value via Recv2 if x, ok := c.Recv2(); x != 1 || !ok { println("testasync1: Recv did not get 1, true:", x, ok, c.Impl()) failed = true } test1(c) } func testasync3(c Chan) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 17 04:48:57 UTC 2012 - 5.8K bytes - Viewed (0) -
test/struct0.go
// Issue 2232. package main func recv(c chan interface{}) struct{} { return (<-c).(struct{}) } var m = make(map[interface{}]int) func recv1(c chan interface{}) { defer rec() m[(<-c).(struct{})] = 0 } func rec() { recover() } func main() { c := make(chan interface{}) go recv(c) c <- struct{}{} go recv1(c) c <- struct{}{}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 565 bytes - Viewed (0) -
cmd/object-handlers_test.go
// Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(recV2, reqV2) if recV2.Code != testCase.expectedRespStatus { t.Errorf("Test %d: %s: Expected the response status to be `%d`, but instead found `%d`", i+1, instanceType, testCase.expectedRespStatus, recV2.Code) } // read the response body. actualContent, err = io.ReadAll(recV2.Body) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/tests/legalize-tf-communication.mlir
// CHECK: [[RECV0_RETVAL0_TUPLE:%.*]]:2 = "mhlo.recv"([[SEND0_ARG0_TOKEN]]) // CHECK-SAME: channel_handle = #mhlo.channel_handle // CHECK-SAME: handle = // CHECK-SAME: type = 3 // CHECK-SAME: mhlo.frontend_attributes = {_xla_host_transfer_handler_name = "tf_rendezvous", _xla_host_transfer_rendezvous = "recv0_htod_0"}
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 08 18:24:20 UTC 2024 - 38.3K bytes - Viewed (0) -
.git-blame-ignore-revs
Guillaume Nodet <******@****.***> 1669127925 +0100
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 14:38:45 UTC 2022 - 857 bytes - Viewed (0) -
src/image/ycbcr_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package image import ( "image/color" "testing" ) func TestYCbCr(t *testing.T) { rects := []Rectangle{ Rect(0, 0, 16, 16), Rect(1, 0, 16, 16), Rect(0, 1, 16, 16), Rect(1, 1, 16, 16), Rect(1, 1, 15, 16), Rect(1, 1, 16, 15), Rect(1, 1, 15, 15), Rect(2, 3, 14, 15),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 26 00:14:16 UTC 2015 - 3.3K bytes - Viewed (0) -
pilot/test/xdstest/grpc.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/sleep" ) type slowClientStream struct { grpc.ClientStream recv, send time.Duration } func (w *slowClientStream) RecvMsg(m any) error { if w.recv > 0 { sleep.UntilContext(w.Context(), w.recv) log.Infof("delayed recv for %v", w.recv) } return w.ClientStream.RecvMsg(m) } func (w *slowClientStream) SendMsg(m any) error { if w.send > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.4K bytes - Viewed (0) -
src/go/types/signature.go
} if cause != "" { check.errorf(recv, InvalidRecv, "invalid receiver type %s (%s)", rtyp, cause) } case *Basic: check.errorf(recv, InvalidRecv, "cannot define new methods on non-local type %s", rtyp) default: check.errorf(recv, InvalidRecv, "invalid receiver type %s", recv.typ) } }).describef(recv, "validate receiver %s", recv) } sig.params = NewTuple(params...)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 22:06:18 UTC 2024 - 13K bytes - Viewed (0) -
src/cmd/compile/internal/types2/signature.go
} if cause != "" { check.errorf(recv, InvalidRecv, "invalid receiver type %s (%s)", rtyp, cause) } case *Basic: check.errorf(recv, InvalidRecv, "cannot define new methods on non-local type %s", rtyp) default: check.errorf(recv, InvalidRecv, "invalid receiver type %s", recv.typ) } }).describef(recv, "validate receiver %s", recv) } sig.params = NewTuple(params...)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:33:05 UTC 2024 - 12.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/stdlib.go
// // Example: "(*Buffer).Grow" -> (true, "Buffer", "Grow") func (sym *Symbol) SplitMethod() (ptr bool, recv, name string) { if sym.Kind != Method { panic("not a method") } recv, name, _ = strings.Cut(sym.Name, ".") recv = recv[len("(") : len(recv)-len(")")] ptr = recv[0] == '*' if ptr { recv = recv[len("*"):] } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 2.4K bytes - Viewed (0)