toObservable method

StreamObservable<T> toObservable()

Converts any Stream<T> into a StreamObservable<T> and starts listening.

Implementation

StreamObservable<T> toObservable() {
  final observable = StreamObservable<T>();
  observable.listen(this);
  return observable;
}