Refactor SpinifySubscriptionMixin to use specific implementation clas…

…ses for client and server subscriptions
PlugFox · Jun 11, 2024 · 0d3f7bb · 0d3f7bb
1 parent 86cd2fc
commit 0d3f7bb
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/lib/src/subscription_impl.dart b/lib/src/subscription_impl.dart
@@ -37,14 +37,16 @@ abstract base class SpinifySubscriptionBase implements SpinifySubscription {
     return target;
   }
 
-  final StreamController<SpinifyChannelEvent> _stateController =
-      StreamController<SpinifyChannelEvent>.broadcast();
+  SpinifySubscriptionState _state =
+      SpinifySubscriptionState.unsubscribed(code: 0, reason: 'initial state');
+  final StreamController<SpinifySubscriptionState> _stateController =
+      StreamController<SpinifySubscriptionState>.broadcast();
 
   final StreamController<SpinifyChannelEvent> _eventController =
       StreamController<SpinifyChannelEvent>.broadcast();
 
   @override
-  SpinifySubscriptionState get state => throw UnimplementedError();
+  SpinifySubscriptionState get state => _state;
 
   @override
   SpinifySubscriptionStateStream get states => throw UnimplementedError();
@@ -59,6 +61,11 @@ abstract base class SpinifySubscriptionBase implements SpinifySubscription {
     // TODO(plugfox): update since position
   }
 
+  @mustCallSuper
+  void setState(SpinifySubscriptionState state) {
+    _stateController.add(_state = state);
+  }
+
   @mustCallSuper
   void close() {
     _stateController.close().ignore();