diff --git a/client/internal/wsreceiver_test.go b/client/internal/wsreceiver_test.go index c929f8fa..01f70592 100644 --- a/client/internal/wsreceiver_test.go +++ b/client/internal/wsreceiver_test.go @@ -212,6 +212,7 @@ func TestReceiverLoopStop(t *testing.T) { receiverLoopStopped.Store(true) }() cancel() + conn.Close() assert.Eventually(t, func() bool { return receiverLoopStopped.Load()