LxStream<T> constructor

LxStream<T>(
  1. Stream<T> stream, {
  2. T? initial,
})

Creates an LxStream bound to the given stream.

Implementation

LxStream(Stream<T> stream, {T? initial})
    : super(_LxAsyncVal.initialStatus<T>(initial),
          onListen: null, onCancel: null) {
  _bind(stream);
}