1.0.0

Author: hoc081098

lib/src/async/async_queue.dart

@@ -78,9 +78,12 @@ class AsyncQueue<T> {
 
   /// Add block to queue.
   Future<T> enqueue(AsyncQueueBlock<T> block) {
-    if (_bag.isDisposed) {
-      throw StateError('AsyncQueue has been disposed!');
-    }
+    assert(() {
+      if (_bag.isClearing || _bag.isDisposed) {
+        throw StateError('AsyncQueue has been disposed!');
+      }
+      return true;
+    }());
 
     final completer = Completer<T>.sync();
     _blockS.add(_AsyncQueueEntry(completer, block));

lib/src/impl/real_storage.dart

@@ -87,16 +87,12 @@ class RealRxStorage<Key extends Object, Options,
   void _publishLog(LoggerEvent<Key, Options> event) {
     assert(_debugAssertNotDisposed());
 
-    try {
-      _loggerEventController!.add(event);
-    } on StateError {
-      assert(_debugAssertNotDisposed());
-    }
+    _loggerEventController!.add(event);
   }
 
   bool _debugAssertNotDisposed() {
     assert(() {
-      if (_bag.isDisposed && _disposeMemo.hasRun) {
+      if (_bag.isClearing || _bag.isDisposed) {
         throw StateError('A $runtimeType was used after being disposed.\n'
             'Once you have called dispose() on a $runtimeType, it can no longer be used.');
       }