don't add to the sink if the taskQueue is closed

daixianceng · Jan 26, 2021 · 67d2249 · 67d2249
1 parent a9f49f6
commit 67d2249
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/packages/state_queue/lib/src/state_queue.dart b/packages/state_queue/lib/src/state_queue.dart
@@ -188,8 +188,10 @@ abstract class StateQueue<T> extends ValueNotifier<T>
   /// of the bloc can not be awaited properly.
   @protected
   void run(StateUpdater<T> updater) {
-    assert(!_taskQueue.isClosed);
-
+    if(_taskQueue.isClosed) {
+      return;
+    }    
+
     final entry = _UpdaterEntry(
       updater,
       onDone: _pendingOperations.registerPendingOperation('UpdaterEntry'),