Rx<T>.fromStream constructor

Rx<T>.fromStream(
  1. Stream<T> stream, {
  2. required T initial,
  3. void onError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
  4. void onDone()?,
  5. bool? cancelOnError,
})

Implementation

Rx.fromStream(
  Stream<T> stream, {
  required T initial,
  void Function(Object error, StackTrace stackTrace)? onError,
  void Function()? onDone,
  bool? cancelOnError,
})  : _value = initial,
      _controller = StreamController<T>.broadcast() {
  bindStream(
    stream,
    onError: onError,
    onDone: onDone,
    cancelOnError: cancelOnError,
  );
}