FSharpPlus


Observable Module

Additional operations on Observable<'T>

Types

Type Description

ObservableUpdate<'T>

Union type that represents different messages that can be sent to the IObserver interface. The IObserver type is equivalent to a type that has just OnNext method that gets 'ObservableUpdate' as an argument.

Functions and values

Function or value Description

Observable.asUpdates source

Full Usage: Observable.asUpdates source

Parameters:
Returns: IObservable<ObservableUpdate<'T>>

Turns observable into an observable that only calls OnNext method of the observer, but gives it a discriminated union that represents different kinds of events (error, next, completed)

source : IObservable<'T>
Returns: IObservable<ObservableUpdate<'T>>

Observable.toAsyncSeq source

Full Usage: Observable.toAsyncSeq source

Parameters:
Returns: SeqT<Async<bool>, 'T>
source : IObservable<'T>
Returns: SeqT<Async<bool>, 'T>

Observable.toTaskSeq source

Full Usage: Observable.toTaskSeq source

Parameters:
Returns: SeqT<Task<bool>, 'T>
source : IObservable<'T>
Returns: SeqT<Task<bool>, 'T>