We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9f33323 commit 79f173eCopy full SHA for 79f173e
lib/src/async/async_queue.dart
@@ -25,7 +25,7 @@ class AsyncQueue<T> {
25
static const _timeout = Duration(seconds: 30);
26
27
final _blockS = StreamController<_AsyncQueueEntry<T>>();
28
- final _countS = StreamController<int>();
+ final _countS = StreamController<int>(sync: true);
29
late final DisposeBag _bag;
30
31
/// Construct [AsyncQueue].
0 commit comments