- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestMultiPubSub (0.11 sec)
-
internal/pubsub/pubsub_test.go
t.Fatalf("unexpected error: %v", err) } val := maskString("hello") ps.Publish(val) msg := <-ch1 if msg != val { t.Fatalf("expected %s , found %s", val, msg) } } func TestMultiPubSub(t *testing.T) { ps := New[Maskable, Maskable](2) ch1 := make(chan Maskable, 1) ch2 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 5.8K bytes - Viewed (0)