toObservable method

StreamObservable<T> toObservable()

Converts any Stream into a StreamObservable and starts listening.

Implementation

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