WIP

events/simple_test.go

@@ -108,3 +108,27 @@ func TestSimpleSubscribersDontRecieveItemsAfterUnsubscribing(t *testing.T) {
 	// closing the channel will result in reads yielding the default value
 	assert.Equal(t, 0, <-ch)
 }
+func TestSimpleEachSubscribersRecievesEachItemGivenBufferedEventChan2(t *testing.T) {
+	c := NewSimpleChannel[Update](10000000, 5)
+	for i := 0; i < 1000; i++ {
+		sub, err := c.Subscribe()
+		if err != nil {
+			panic(err)
+		}
+		defer c.Unsubscribe(sub)
+		go handleChannelMessages(sub)
+	}
+	for i := 0; i < 100; i++ {
+		c.Publish(
+			Update{
+				DocID: "test",
+			},
+		)
+	}
+}
+func handleChannelMessages(sub Subscription[Update]) {
+	for msg := range sub {
+		_ = msg
+		time.Sleep(100 * time.Millisecond)
+	}
+}