- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestSubscribeExceedingLimit (0.23 sec)
-
internal/pubsub/pubsub_test.go
t.Fatalf("want %d subscribers, got %d", want, got) } if want, got := int32(0), ps.NumSubscribers(Mask(4)); got != want { t.Fatalf("want %d subscribers, got %d", want, got) } } func TestSubscribeExceedingLimit(t *testing.T) { ps := New[Maskable, Maskable](2) ch1 := make(chan Maskable, 1) ch2 := make(chan Maskable, 1) ch3 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0)