RxStreamExtension<T> extension

Convert a Stream to RxStream.

on

Methods

asRx() RxStream<T>
Convert a Stream to RxStream.