StreamObservableExtension<T> extension

Extension on Stream to easily convert it to a StreamObservable.

on

Methods

toObservable() → StreamObservable<T>

Available on Stream<T>, provided by the StreamObservableExtension extension

Converts any Stream into a StreamObservable and starts listening.