StreamOutput<T> constructor
StreamOutput<T> (})
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}';
}