StreamOutput<T> constructor

StreamOutput<T>(
  1. Stream<T> source, {
  2. required T seedValue,
  3. required String semantics,
  4. bool sync = true,
  5. bool printLog = true,
  6. bool isBehavior = true,
  7. T onReset()?,
  8. PersistConfig<T>? persistConfig,
  9. bool skipError = false,
})

Implementation

StreamOutput(
  final Stream<T> source, {
  required super.seedValue,
  required super.semantics,
  super.sync = true,
  super.printLog = true,
  super.isBehavior = true,
  super.onReset,
  super.persistConfig,
  super.skipError,
}) {
  _sourceSubscription = source.listen(_subject.add);
  stream = _subject.stream;
  _fetch = (_) => throw 'StreamOutput不应调用update方法!\n${StackTrace.current}';
}