Check channel before subscribe

PlugFox · Aug 3, 2023 · 0f8a39d · 0f8a39d
1 parent 30f7662
commit 0f8a39d
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/lib/src/client/centrifuge.dart b/lib/src/client/centrifuge.dart
@@ -500,8 +500,17 @@ base mixin CentrifugeClientSubscriptionMixin
   CentrifugeClientSubscription newSubscription(
     String channel, [
     CentrifugeSubscriptionConfig? config,
-  ]) =>
-      _clientSubscriptionManager.newSubscription(channel, config);
+  ]) {
+    final sub = _clientSubscriptionManager[channel] ??
+        _serverSubscriptionManager[channel];
+    if (sub != null) {
+      throw CentrifugeSubscriptionException(
+        channel: channel,
+        message: 'Subscription already exists',
+      );
+    }
+    return _clientSubscriptionManager.newSubscription(channel, config);
+  }
 
   @override
   Map<String, CentrifugeClientSubscription> get subscriptions =>