asRx method

RxStream<T> asRx()

Convert a Stream to RxStream.

Implementation

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