ObservableStreamExtension<T> extension

Turn the Stream into an ObservableStream.

on
  • Stream<T>

Methods

asObservable({T initialValue, bool cancelOnError, ReactiveContext context}) ObservableStream<T>