fromStream<T> static method

Signal<T> fromStream<T>(
  1. Stream<T> stream,
  2. T initialValue
)

Create a signal from a stream.

Implementation

static Signal<T> fromStream<T>(Stream<T> stream, T initialValue) {
  final signal = Signal<T>(initialValue);
  stream.listen((value) => signal.emit(value));
  return signal;
}