ofChannel<T> static method

ControlObservable<T?> ofChannel<T>(
  1. ObservableChannel channel
)

Implementation

static ControlObservable<T?> ofChannel<T>(ObservableChannel channel) {
  final observable = _ClientObservable<T>();

  channel.subscribe(() => observable.notify());

  return observable;
}