- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestPubSub (0.17 sec)
-
internal/pubsub/pubsub_test.go
if len(ps.subs) != 1 { t.Fatal("expected 1 subscriber") } ps.Unlock() close(doneCh2) } type maskString string func (m maskString) Mask() uint64 { return 1 } func TestPubSub(t *testing.T) { ps := New[Maskable, Maskable](1) ch1 := make(chan Maskable, 1) doneCh1 := make(chan struct{}) defer close(doneCh1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.8K bytes - Viewed (0)