Qbservable.Do(TSource) Method (IQbservable(TSource), Expression(Action(TSource)), Expression(Action(Exception)), Expression(Action))
Invokes an action for each element in the queryable observable sequence, and invokes an action upon graceful or exceptional termination of the queryable observable sequence.
Namespace: System.Reactive.Linq
Assembly: System.Reactive.Providers (in System.Reactive.Providers.dll)
static member Do : source:IQbservable<'TSource> * onNext:Expression<Action<'TSource>> * onError:Expression<Action<Exception>> * onCompleted:Expression<Action> -> IQbservable<'TSource>
Type Parameters
- TSource
The type of source.
Parameters
- source
- Type: System.Reactive.Linq.IQbservable(TSource)
The source sequence.
- onNext
- Type: System.Linq.Expressions.Expression(Action(TSource))
The action to invoke for each element in the queryable observable sequence.
- onError
- Type: System.Linq.Expressions.Expression(Action(Exception))
The action to invoke upon exceptional termination of the queryable observable sequence.
- onCompleted
- Type: System.Linq.Expressions.Expression(Action)
The action to invoke upon graceful termination of the queryable observable sequence.
Return Value
Type: System.Reactive.Linq.IQbservable(TSource)The source sequence with the side-effecting behavior applied.