ofStream<T> static method

ControlObservable<T?> ofStream<T>(
  1. Stream<T> stream
)

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;
}