PersistentStateNotifier<T> constructor

PersistentStateNotifier<T>({ required PersistentStore<T> store, Duration saveDebounce = const Duration(milliseconds: 1000), })

Implementation

PersistentStateNotifier({
  required this.store,
  Duration saveDebounce = const Duration(milliseconds: 1000),
}) : super(const AsyncValue.loading()) {
  _initFuture = store.init();
  _initFuture.then(_load);

  _saveSub = stream
      .delayWhen((event) => _initFuture.asStream())
      .whereType<AsyncData<T>>()
      .debounceTime(saveDebounce)
      .listen(_save);
}