StreamSignal<T> constructor

StreamSignal<T>(
  1. Stream<T> source, {
  2. required T initialValue,
  3. String? debugLabel,
})

Implementation

StreamSignal(
  this.source, {
  required T initialValue,
  String? debugLabel,
}) : super(initialValue, debugLabel: debugLabel) {
  _subscription = source.listen(
    (value) => emit(value),
    onError: (error) {
      if (kDebugMode) print('StreamSignal error: $error');
    },
  );
}