of<T> static method

RxStream<T> of<T>(Stream<T> stream)

Implementation

static RxStream<T> of<T>(Stream<T> stream) => RxStream._(stream);