AsyncSignal<T>.fromStream constructor

AsyncSignal<T>.fromStream(
  1. Stream<T> stream, {
  2. JoltDebugOption? debug,
})

Creates an async signal from a Stream.

Parameters:

  • stream: The stream to wrap

Returns: An AsyncSignal that manages the stream's lifecycle

Example:

final signal = AsyncSignal.fromStream(
  Stream.periodic(Duration(seconds: 1), (i) => i)
);

Implementation

factory AsyncSignal.fromStream(Stream<T> stream, {JoltDebugOption? debug}) =>
    AsyncSignalImpl(source: StreamSource(stream), debug: debug);