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;
}