LxStream<T> constructor

LxStream<T>(
  1. Stream<T> stream, {
  2. T? initial,
  3. LxStreamCompletionPolicy completionPolicy = LxStreamCompletionPolicy.close,
})

Creates an LxStream bound to the given stream. Note: If the stream is a single-subscription stream, it cannot be safely re-listened to after losing all subscribers. Prefer using LxStream.defer for single-subscription streams.

Implementation

factory LxStream(
  Stream<T> stream, {
  T? initial,
  LxStreamCompletionPolicy completionPolicy = LxStreamCompletionPolicy.close,
}) {
  return LxStream<T>._internal(
    _LxAsyncVal.initialStatus<T>(initial),
    () => stream,
    completionPolicy,
  );
}