Method Process

Namespace

Bonsai.Reactive

Assembly

Bonsai.Core.dll

Process<TSource>(IObservable<TSource>)

Applies a timeout policy for each element in the observable sequence. If the next element is not received within the specified timeout duration from the previous element, a TimeoutException is propagated to the observer.

public override IObservable<TSource> Process<TSource>(IObservable<TSource> source)

Parameters

source IObservable<TSource>

The source sequence to perform a timeout for.

Returns

IObservable<TSource>

A sequence which is identical to the source sequence, but where a TimeoutException is raised if more than the specified timout duration lapses between consecutive elements.

Type Parameters

TSource

The type of the elements in the source sequence.