asRx method

RxStream<T> asRx()

Implementation

RxStream<T> asRx() => RxStream.of<T>(this);