Function newBufferedSubscribeTestServer

coderd/x/chatd/chatd_internal_test.go:2785–2794

(t *testing.T, db database.Store, chatID uuid.UUID)

}

func newBufferedSubscribeTestServer(t *testing.T, db database.Store, chatID uuid.UUID) *Server {
	t.Helper()

	server := newSubscribeTestServer(t, db)
	state := server.getOrCreateStreamState(chatID)
	state.mu.Lock()
	state.buffering = true
	state.mu.Unlock()
	return server
}

func requireStreamMessageEvent(t *testing.T, events <-chan codersdk.ChatStreamEvent) codersdk.ChatStreamEvent {
	t.Helper()