toObservable method
Converts any Stream into a StreamObservable and starts listening.
Implementation
StreamObservable<T> toObservable() {
final observable = StreamObservable<T>();
observable.listen(this);
return observable;
}
Converts any Stream into a StreamObservable and starts listening.
StreamObservable<T> toObservable() {
final observable = StreamObservable<T>();
observable.listen(this);
return observable;
}