update disposebag

Author: hoc081098

lib/src/async/async_queue.dart

@@ -26,11 +26,13 @@ class AsyncQueue<T> {
 
   final _blockS = StreamController<_AsyncQueueEntry<T>>();
   final _countS = StreamController<int>();
-  late final _bag =
-      DisposeBag(const <Object>[], 'AsyncQueue#${shortHash(this)}');
+  late final DisposeBag _bag;
 
   /// Construct [AsyncQueue].
-  AsyncQueue(void Function() onTimeout) {
+  AsyncQueue(Object key, void Function() onTimeout) {
+    _bag = DisposeBag(
+        const <Object>[], '( AsyncQueue ~ $key ~ ${shortHash(this)} )');
+
     _blockS.disposedBy(_bag);
     _countS.disposedBy(_bag);
 

lib/src/impl/real_storage.dart

@@ -30,7 +30,7 @@ class RealRxStorage<Key extends Object, Options,
 
   final _disposeMemo = AsyncMemoizer<void>();
   late final _bag =
-      DisposeBag(const <Object>[], 'RealRxStorage#${shortHash(this)}');
+      DisposeBag(const <Object>[], '( RealRxStorage ~ ${shortHash(this)} )');
 
   /// Logger controller. Nullable
   StreamController<LoggerEvent<Key, Options>>? _loggerEventController;
@@ -114,7 +114,9 @@ class RealRxStorage<Key extends Object, Options,
         .putIfAbsent(
           key,
           () => AsyncQueue<Object?>(
-              () => _writeQueueResources.remove(key)?.dispose()),
+            key,
+            () => _writeQueueResources.remove(key)?.dispose(),
+          ),
         )
         .enqueue(block)
         .then((value) => value as T);

pubspec.yaml

@@ -17,5 +17,5 @@ dependencies:
 
 dev_dependencies:
   pedantic: ^1.11.0
-  test: ^1.16.8
+  test: ^1.17.1
   collection: ^1.15.0