LxStream<T>.idle constructor

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

Creates an LxStream in an LxIdle state.

Implementation

factory LxStream.idle({
  T? initial,
  LxStreamCompletionPolicy completionPolicy = LxStreamCompletionPolicy.close,
}) {
  return LxStream<T>._internal(
    _LxAsyncVal.initialStatus<T>(initial, idle: true),
    null,
    completionPolicy,
  );
}