- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for sendZero (0.78 sec)
-
src/cmd/compile/internal/syntax/testdata/map2.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans_Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) } go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 12:49:49 UTC 2023 - 3.4K bytes - Viewed (0) -
src/internal/types/testdata/check/map1.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans_Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 3.4K bytes - Viewed (0) -
test/chan/select2.go
runtime.MemProfileRate = 0 c := make(chan int) dummy := make(chan int) // warm up go sender(c, 100000) receiver(c, dummy, 100000) runtime.GC() memstats := new(runtime.MemStats) runtime.ReadMemStats(memstats) alloc := memstats.Alloc // second time shouldn't increase footprint by much go sender(c, 100000) receiver(c, dummy, 100000) runtime.GC() runtime.ReadMemStats(memstats)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/process/internal/NoCleanUpRemoteProcess.java
lock.lock(); } }).start(); TestListenerInterface sender = workerProcessContext.getServerConnection().addOutgoing(TestListenerInterface.class); workerProcessContext.getServerConnection().connect(); sender.send("message 1", 1); sender.send("message 2", 2); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 06 17:14:50 UTC 2016 - 1.5K bytes - Viewed (0) -
src/internal/types/testdata/check/map0.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans.Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 17 19:54:25 UTC 2023 - 2.8K bytes - Viewed (0) -
src/compress/gzip/example_test.go
go func() { defer close(errch) sentErr := false sendErr := func(err error) { if !sentErr { errch <- err sentErr = true } } // Copy our data to gzipWriter, which compresses it to // gzipWriter, which feeds it to bodyReader. if _, err := io.Copy(gzipWriter, dataReader); err != nil && err != io.ErrClosedPipe { sendErr(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 22 16:24:14 UTC 2022 - 4.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/process/internal/RemoteProcess.java
throw new RuntimeException(e); } // Send some messages TestListenerInterface sender = workerProcessContext.getServerConnection().addOutgoing(TestListenerInterface.class); workerProcessContext.getServerConnection().connect(); sender.send("message 1", 1); sender.send("message 2", 2); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jul 14 01:36:23 UTC 2021 - 2.3K bytes - Viewed (0) -
src/go/parser/testdata/map.go2
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans.Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && // TODO // sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 24 19:44:06 UTC 2020 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch_test.go
} } _, stillOpen := <-w.ResultChan() if stillOpen { t.Fatal("Never stopped") } } sender := func() { f.Add(testType("foo")) f.Action(Modified, testType("qux")) f.Modify(testType("bar")) f.Delete(testType("bar")) f.Error(testType("error: blah")) f.Stop() } go sender() consumer(f) } func TestRaceFreeFake(t *testing.T) { f := NewRaceFreeFake() table := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 15 11:34:31 UTC 2018 - 3.7K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/map.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans.Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 30 18:02:18 UTC 2022 - 2.8K bytes - Viewed (0)