Store<St> constructor

Store<St>({
  1. required St initialState,
  2. Object? environment,
  3. Map<Object?, Object?> props = const {},
  4. bool syncStream = false,
  5. TestInfoPrinter? testInfoPrinter,
  6. List<ActionObserver<St>>? actionObservers,
  7. List<StateObserver<St>>? stateObservers,
  8. Persistor<St>? persistor,
  9. ModelObserver? modelObserver,
  10. ErrorObserver<St>? errorObserver,
  11. WrapReduce<St>? wrapReduce,
  12. @Deprecated("Use `globalWrapError` instead. This will be removed.") WrapError<St>? wrapError,
  13. GlobalWrapError<St>? globalWrapError,
  14. bool? defaultDistinct,
  15. CompareBy? immutableCollectionEquality,
  16. int? maxErrorsQueued,
})

Implementation

Store({
  required St initialState,
  Object? environment,
  Map<Object?, Object?> props = const {},
  bool syncStream = false,
  TestInfoPrinter? testInfoPrinter,
  List<ActionObserver<St>>? actionObservers,
  List<StateObserver<St>>? stateObservers,
  Persistor<St>? persistor,
  ModelObserver? modelObserver,
  ErrorObserver<St>? errorObserver,
  WrapReduce<St>? wrapReduce,
  @Deprecated("Use `globalWrapError` instead. This will be removed.") WrapError<St>? wrapError,
  GlobalWrapError<St>? globalWrapError,
  bool? defaultDistinct,
  CompareBy? immutableCollectionEquality,
  int? maxErrorsQueued,
})  : _state = initialState,
      _environment = environment,
      _props = HashMap()..addAll(props),
      _stateTimestamp = DateTime.now().toUtc(),
      _changeController = StreamController.broadcast(sync: syncStream),
      _actionObservers = actionObservers,
      _stateObservers = stateObservers,
      _processPersistence = persistor == null
          ? //
          null
          : ProcessPersistence(persistor, initialState),
      _modelObserver = modelObserver,
      _errorObserver = errorObserver,
      _wrapError = wrapError,
      _globalWrapError = globalWrapError,
      _wrapReduce = wrapReduce,
      _defaultDistinct = defaultDistinct ?? true,
      _immutableCollectionEquality = immutableCollectionEquality,
      _errors = Queue<UserException>(),
      _maxErrorsQueued = maxErrorsQueued ?? 10,
      _dispatchCount = 0,
      _reduceCount = 0,
      _shutdown = false,
      _testInfoPrinter = testInfoPrinter,
      _testInfoController = (testInfoPrinter == null)
          ? //
          null
          : StreamController.broadcast(sync: syncStream);