diff --git a/lib/src/services/streaming_service_impl.dart b/lib/src/services/streaming_service_impl.dart
index 2c4e4b7..34ce4ca 100644
--- a/lib/src/services/streaming_service_impl.dart
+++ b/lib/src/services/streaming_service_impl.dart
@@ -116,7 +116,10 @@ class StreamingService implements StreamingController, WebSocketController {
       }
       final subNotes = _subNotes;
       for (final subscriptedNotes in subNotes) {
-        subNote(subscriptedNotes);
+        sendRequest(
+          StreamingRequestType.subNote,
+          StreamingRequestBody(id: subscriptedNotes, params: {}),
+        );
       }
     } catch (e) {
       if (retryCounts < maxRetryCounts) {