diff --git a/lib/src/services/streaming_service_impl.dart b/lib/src/services/streaming_service_impl.dart
index 9bd0342..d1bcc94 100644
--- a/lib/src/services/streaming_service_impl.dart
+++ b/lib/src/services/streaming_service_impl.dart
@@ -196,6 +196,7 @@ class StreamingService implements StreamingController, WebSocketController {
       _connections.removeWhere((e) => e.id == id);
       _activeStreams--;
       if (_activeStreams == 0) {
+        _subNotes.clear();
         final lock = await _connectWebSocketMutex.acquire();
         if (_connections.isEmpty) {
           log("attempt $host streaming closed...");