ofStream<T> static method
Implementation
static ControlObservable<T?> ofStream<T>(Stream<T> stream) {
final observable = _ClientObservable<T>();
final sub = stream.listen((event) => observable.setValue(event));
observable.register(DisposableClient()..onDispose = () => sub.cancel());
return observable;
}