toStream method

Stream<T> toStream()

Returns a Stream that subscribes to and emits the values of this Observable.

Implementation

Stream<T> toStream() {
  final disposable = SequentialDisposable();
  final controller = StreamController<T>();
  controller.onListen = () {
    disposable.current = subscribe(Observer<T>(
      next: controller.add,
      error: controller.addError,
      complete: controller.close,
    ));
  };
  controller.onCancel = disposable.dispose;
  return controller.stream;
}