add sealed ScopeState

Author: wupididu

packages/yx_scope/lib/src/core/scope_state.dart

@@ -1,12 +1,34 @@
-enum ScopeState {
-  none,
-  initializing,
-  available,
-  disposing,
+abstract class ScopeState<Scope> {
+  ScopeState._();
+
+  factory ScopeState.none() = ScopeStateNone;
+  factory ScopeState.initializing() = ScopeStateInitializing;
+  factory ScopeState.available({required Scope scope}) = ScopeStateAvailable;
+  factory ScopeState.disposing() = ScopeStateDisposing;
+
+  bool get none => this is ScopeStateNone;
+
+  bool get initializing => this is ScopeStateInitializing;
+
+  bool get available => this is ScopeStateAvailable;
+
+  bool get disposing => this is ScopeStateDisposing;
 }
 
-extension ScopeStateExt on ScopeState {
-  bool get none => this == ScopeState.none;
+class ScopeStateNone<Scope> extends ScopeState<Scope> {
+  ScopeStateNone() : super._();
+}
+
+class ScopeStateInitializing<Scope> extends ScopeState<Scope> {
+  ScopeStateInitializing() : super._();
+}
+
+class ScopeStateAvailable<Scope> extends ScopeState<Scope> {
+  final Scope scope;
+
+  ScopeStateAvailable({required this.scope}) : super._();
+}
 
-  bool get available => this == ScopeState.available;
+class ScopeStateDisposing<Scope> extends ScopeState<Scope> {
+  ScopeStateDisposing() : super._();
 }

packages/yx_scope/lib/src/core/scope_state_holder.dart

@@ -1,21 +1,31 @@
 part of '../base_scope_container.dart';
 
-typedef StateListener<S> = void Function(S scope);
+typedef StateListener<S> = void Function(S? scope);
+
+typedef ScopeStateListener<S> = void Function(ScopeState<S> state);
 
 typedef RemoveStateListener = void Function();
 
 class ScopeStateHolder<Scope> {
   final _listeners = LinkedList<Entry<Scope>>();
-  Scope _scope;
+  ScopeState<Scope> _state;
 
   bool _debugCanAddListeners = true;
 
-  ScopeStateHolder(Scope state) : _scope = state;
+  ScopeStateHolder(this._state);
 
-  Scope get scope => _scope;
+  Scope? get scope {
+    final state = this.state;
+    if (state is ScopeStateAvailable<Scope>) {
+      return state.scope;
+    }
+    return null;
+  }
 
-  void _setScope(Scope state) {
-    _scope = state;
+  ScopeState<Scope> get state => _state;
+
+  void _updateState(ScopeState<Scope> state) {
+    _state = state;
 
     final errors = <Object>[];
     final stackTraces = <StackTrace>[];
@@ -50,6 +60,42 @@ class ScopeStateHolder<Scope> {
   RemoveStateListener listen(
     StateListener<Scope> listener, {
     bool emitImmediately = false,
+  }) =>
+      _listen(
+        (state) {
+          if (state is ScopeStateAvailable<Scope>) {
+            listener(state.scope);
+          } else if (state is ScopeStateNone) {
+            listener(null);
+          }
+        },
+        emitImmediately: emitImmediately,
+      );
+
+  /// Subscribes to the state.
+  ///
+  /// The [listener] callback will be called immediately on addition and
+  /// synchronously whenever [state] changes.
+  ///
+  /// Set [emitImmediately] to true if you want to an immediate execution
+  /// of the [listener] with the current state.
+  ///
+  /// To remove this [listener], call the function returned by [listen].
+  ///
+  /// Listeners cannot add other listeners.
+  /// Adding and removing listeners has a constant time-complexity.
+  RemoveStateListener listenState(
+    ScopeStateListener<Scope> listener, {
+    bool emitImmediately = false,
+  }) =>
+      _listen(
+        (state) => listener(state),
+        emitImmediately: emitImmediately,
+      );
+
+  RemoveStateListener _listen(
+    void Function(ScopeState<Scope> state) listener, {
+    bool emitImmediately = false,
   }) {
     assert(() {
       if (!_debugCanAddListeners) {
@@ -64,7 +110,7 @@ class ScopeStateHolder<Scope> {
         // Intentionally unsafe call of the listener before adding to the [_listeners]
         // so that if there is an exception — we throw it back to consumer
         // with an original stacktrace without adding to the [_listeners].
-        listener(scope);
+        listener(state);
       } on Object catch (_) {
         rethrow;
       } finally {
@@ -93,7 +139,7 @@ class ScopeStateHolder<Scope> {
 class Entry<T> extends LinkedListEntry<Entry<T>> {
   Entry(this.listener);
 
-  final StateListener<T> listener;
+  final ScopeStateListener<T> listener;
 }
 
 /// An error thrown when tried to update the state of a [ScopeStateHolder],