Function newSubscribers

coderd/x/chatd/streamcollector_internal_test.go:163–170

(t *testing.T, n int)

}

func newSubscribers(t *testing.T, n int) map[uuid.UUID]chan codersdk.ChatStreamEvent {
	t.Helper()
	subs := make(map[uuid.UUID]chan codersdk.ChatStreamEvent, n)
	for range n {
		subs[uuid.New()] = make(chan codersdk.ChatStreamEvent, 1)
	}
	return subs
}

// TestStreamStateCollector_BufferDroppedIncrementsOnCapacity pre-fills
// a buffer to capacity and asserts stream_buffer_dropped_total