ObservableStreamExtension<T> extension

Turn the Stream into an ObservableStream.

on

• Stream<T>

Methods

asObservable({T? initialValue, bool cancelOnError = false, ReactiveContext? context, String? name}) → ObservableStream<T>

Available on Stream<T>, provided by the ObservableStreamExtension extension