ObservableStreamExtension<T> extension

Turn the Stream into an ObservableStream.

on

Methods

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