We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ede1415 commit bbc8c4aCopy full SHA for bbc8c4a
coderd/database/pubsub_test.go
@@ -140,8 +140,9 @@ func TestPubsub_Disconnect(t *testing.T) {
140
defer pubsub.Close()
141
event := "test"
142
143
- errors := make(chan error)
144
- messages := make(chan string)
+ // buffer responses so that when the test completes, goroutines don't get blocked & leak
+ errors := make(chan error, database.PubsubBufferSize)
145
+ messages := make(chan string, database.PubsubBufferSize)
146
readOne := func() (m string, e error) {
147
t.Helper()
148
select {
0 commit comments