Store<St> constructor
Store<St> ({
- required St initialState,
- Object? environment,
- bool syncStream = false,
- TestInfoPrinter? testInfoPrinter,
- List<
ActionObserver< ? actionObservers,St> > - List<
StateObserver< ? stateObservers,St> > - Persistor<
St> ? persistor, - ModelObserver? modelObserver,
- ErrorObserver<
St> ? errorObserver, - WrapReduce<
St> ? wrapReduce, - WrapError<
St> ? wrapError, - bool? defaultDistinct,
- CompareBy? immutableCollectionEquality,
- int? maxErrorsQueued,
Implementation
Store({
required St initialState,
Object? environment,
bool syncStream = false,
TestInfoPrinter? testInfoPrinter,
List<ActionObserver<St>>? actionObservers,
List<StateObserver<St>>? stateObservers,
Persistor<St>? persistor,
ModelObserver? modelObserver,
ErrorObserver<St>? errorObserver,
WrapReduce<St>? wrapReduce,
WrapError<St>? wrapError,
bool? defaultDistinct,
CompareBy? immutableCollectionEquality,
int? maxErrorsQueued,
}) : _state = initialState,
_environment = environment,
_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,
_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);