AsyncNotifier<T> constructor

AsyncNotifier<T>(T _initial)

Creates a AsyncNotifier with an initial value.

Implementation

AsyncNotifier(this._initial) {
  final future = Future.value(_initial);
  final init = _Snapshot(
    CancelableOperation.fromFuture(future),
    _initial,
    null,
  );
  _subject = BehaviorSubject<_Snapshot<T>>.seeded(init);
  listenToStream(_stream);
  registerSink(_subject);
  unawaited(future.whenComplete(onCreate));
}