- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 128 for bsender (0.2 sec)
-
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/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) -
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) -
src/crypto/internal/hpke/hpke.go
if err != nil { return nil, nil, err } return encapsulatedKey, &Sender{ kem: kem, aead: aead, sharedSecret: sharedSecret, suiteID: suiteID, key: key, baseNonce: baseNonce, exporterSecret: exporterSecret, }, nil } func (s *Sender) nextNonce() []byte { nonce := s.seqNum.bytes()[16-s.aead.NonceSize():]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:33:33 UTC 2024 - 7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/CallInterceptingMetaClass.java
} @Override public Object getProperty(Class sender, Object object, String name, boolean useSuper, boolean fromInsideClass) { if (useSuper || fromInsideClass) { return adaptee.getProperty(sender, object, name, useSuper, fromInsideClass); } else { return invokeIntercepted(object, GET_PROPERTY, name, NO_ARG, () -> adaptee.getProperty(sender, object, name, false, false)); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:46:35 UTC 2024 - 21.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/finisher/finisher.go
return result.Return() case <-ctx.Done(): // we are going to send a timeout response to the caller, but the asynchronous goroutine // (sender) is still executing the ResultFunc function. // kick off a goroutine (receiver) here to wait for the sender (goroutine executing ResultFunc) // to send the result and then log details of the result. defer func() { go func() { timedOutAt := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 14:20:33 UTC 2021 - 6K bytes - Viewed (0) -
pkg/scheduler/framework/parallelize/error_channel.go
// again. type ErrorChannel struct { errCh chan error } // SendError sends an error without blocking the sender. func (e *ErrorChannel) SendError(err error) { select { case e.errCh <- err: default: } } // SendErrorWithCancel sends an error without blocking the sender and calls // cancel function. func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc) { e.SendError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0) -
pkg/volume/util/subpath/subpath_unsupported.go
} // NewNSEnter is to satisfy the compiler for having NewSubpathNSEnter exist for all // OS choices. however, NSEnter is only valid on Linux func NewNSEnter(mounter mount.Interface, ne *nsenter.Nsenter, rootDir string) Interface { return nil } func (sp *subpath) PrepareSafeSubpath(subPath Subpath) (newHostPath string, cleanupAction func(), err error) { return subPath.Path, nil, errUnsupported }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 1.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/internal/PluginConfigurationModule.java
this.plugin = plugin; } @Override public void configure(Binder binder) { if (plugin.getKey() != null) { XmlNode configuration = plugin.getConfiguration(); if (configuration == null) { configuration = new XmlNodeImpl("configuration"); } binder.bind(XmlNode.class) .annotatedWith(Names.named(plugin.getKey()))
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Sep 22 07:14:56 UTC 2023 - 2K bytes - Viewed (0) -
src/runtime/race/testdata/chan_test.go
_ = data[i] } } // Test that sender synchronizes with receiver even if the sender was blocked. func TestNoRaceBlockedSendSync(t *testing.T) { c := make(chan *int, 1) c <- nil go func() { i := 42 c <- &i }() // Give the sender time to actually block. // This sleep is completely optional: race report must not be printed // regardless of whether the sender actually blocks or not.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 11K bytes - Viewed (0)