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

net8.0, net8.0-windows10.0.19041, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, 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)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
source[IQbservable](#--
observerIObserver--

Returns: IQbservable

2. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
source[IQbservable](#--
onNextExpression>--

Returns: IQbservable

3. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
source[IQbservable](#--
onNextExpression>--
onCompletedExpression--

Returns: IQbservable

4. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
source[IQbservable](#--
onNextExpression>--
onErrorExpression>--

Returns: IQbservable

5. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
source[IQbservable](#--
onNextExpression>--
onErrorExpression>--
onCompletedExpression--

Returns: IQbservable