Skip to content

,System.IObserver{--0})} ,System.Linq.Expressions.Expression{System.Action{--0}})} ,System.Linq.Expressions.Expression{System.Action{--0}},System.Linq.Expressions.Expression{System.Action})} ,System.Linq.Expressions.Expression{System.Action{--0}},System.Linq.Expressions.Expression{System.Action{System.Exception}})} ,System.Linq.Expressions.Expression{System.Action{--0}},System.Linq.Expressions.Expression{System.Action{System.Exception}},System.Linq.Expressions.Expression{System.Action})}

Qbservable.Do(IQbservable, IObserver) method

Defined in

Type: Qbservable Namespace: System.Reactive.Linq Assembly: System.Reactive.dll

Applies to

netstandard2.0

Overloads

  • 1. public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, IObserver<TSource> observer)
  • 2. public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext)
  • 3. public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action> onCompleted)
  • 4. public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action<Exception>> onError)
  • 5. public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action<Exception>> onError, Expression<Action> onCompleted)

1. Overload

public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, IObserver<TSource> observer)

Summary: Invokes the observer's methods for each message in the source sequence. This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.

Type parameters

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence.
observerIObserverObserver whose methods to invoke as part of the source sequence's observation.

Returns: IQbservable -- The source sequence with the side-effecting behavior applied.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource or observer is null.

2. Overload

public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext)

Summary: Invokes an action for each element in the observable sequence, and propagates all observer messages through the result sequence. This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.

Type parameters

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence.
onNextExpression>Action to invoke for each element in the observable sequence.

Returns: IQbservable -- The source sequence with the side-effecting behavior applied.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource or onNext is null.

3. Overload

public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action> onCompleted)

Summary: Invokes an action for each element in the observable sequence and invokes an action upon graceful termination of the observable sequence. This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.

Type parameters

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence.
onNextExpression>Action to invoke for each element in the observable sequence.
onCompletedExpressionAction to invoke upon graceful termination of the observable sequence.

Returns: IQbservable -- The source sequence with the side-effecting behavior applied.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource or onNext or onCompleted is null.

4. Overload

public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action<Exception>> onError)

Summary: Invokes an action for each element in the observable sequence and invokes an action upon exceptional termination of the observable sequence. This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.

Type parameters

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence.
onNextExpression>Action to invoke for each element in the observable sequence.
onErrorExpression>Action to invoke upon exceptional termination of the observable sequence.

Returns: IQbservable -- The source sequence with the side-effecting behavior applied.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource or onNext or onError is null.

5. Overload

public static IQbservable<TSource> Do<TSource>(this IQbservable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action<Exception>> onError, Expression<Action> onCompleted)

Summary: Invokes an action for each element in the observable sequence and invokes an action upon graceful or exceptional termination of the observable sequence. This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.

Type parameters

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence.
onNextExpression>Action to invoke for each element in the observable sequence.
onErrorExpression>Action to invoke upon exceptional termination of the observable sequence.
onCompletedExpressionAction to invoke upon graceful termination of the observable sequence.

Returns: IQbservable -- The source sequence with the side-effecting behavior applied.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource or onNext or onError or onCompleted is null.