Removes the lock I put on 👀

Author: gloriousCode

exchanges/stream/websocket.go

@@ -342,9 +342,9 @@ func (w *Websocket) connectionMonitor() error {
 	if w.checkAndSetMonitorRunning() {
 		return errAlreadyRunning
 	}
-	w.m.Lock()
+	w.connectionMutex.RLock()
 	delay := w.connectionMonitorDelay
-	w.m.Unlock()
+	w.connectionMutex.RUnlock()
 
 	go func() {
 		timer := time.NewTimer(delay)

exchanges/stream/websocket_test.go

@@ -603,6 +603,7 @@ func TestConnectionMonitorNoConnection(t *testing.T) {
 	if !errors.Is(err, errAlreadyRunning) {
 		t.Fatalf("received: %v, but expected: %v", err, errAlreadyRunning)
 	}
+	ws.setEnabled(false)
 }
 
 // TestSliceCopyDoesntImpactBoth logic test