use dev version of async and bloc tools

This commit is contained in:
Christien Rioux 2024-05-07 10:03:41 -05:00
parent 25a6a00fcf
commit 627066dd27
9 changed files with 21 additions and 17 deletions

View file

@ -112,7 +112,7 @@ class DHTRecordCubit<T> extends Cubit<AsyncValue<T>> {
DHTRecord get record => _record;
@protected
final WaitSet initWait = WaitSet();
final WaitSet<void> initWait = WaitSet();
StreamSubscription<DHTRecordWatchChange>? _subscription;
late DHTRecord _record;

View file

@ -121,7 +121,7 @@ class DHTShortArrayCubit<T> extends Cubit<DHTShortArrayBusyState<T>>
return _shortArray.operateWriteEventual(closure, timeout: timeout);
}
final WaitSet _initWait = WaitSet();
final WaitSet<void> _initWait = WaitSet();
late final DHTShortArray _shortArray;
final T Function(List<int> data) _decodeElement;
StreamSubscription<void>? _subscription;

View file

@ -42,6 +42,6 @@ abstract class AsyncTableDBBackedCubit<T> extends Cubit<AsyncValue<T?>>
}
}
final WaitSet _initWait = WaitSet();
final WaitSet<void> _initWait = WaitSet();
final Mutex _mutex = Mutex();
}

View file

@ -185,7 +185,7 @@ class PersistentQueue<T extends GeneratedMessage>
final String _key;
final T Function(Uint8List) _fromBuffer;
final bool _deleteOnClose;
final WaitSet _initWait = WaitSet();
final WaitSet<void> _initWait = WaitSet();
final Mutex _queueMutex = Mutex();
IList<T> _queue = IList<T>.empty();
final StreamController<Iterable<T>> _syncAddController = StreamController();

View file

@ -172,7 +172,7 @@ class TableDBValue<T> extends TableDBBackedJson<T> {
final T? Function(Object? obj) _valueFromJson;
final Object? Function(T? obj) _valueToJson;
final StreamController<T> _streamController;
final WaitSet _initWait = WaitSet();
final WaitSet<void> _initWait = WaitSet();
//////////////////////////////////////////////////////////////
/// AsyncTableDBBacked