Skip to content

)} ,System.Reactive.Concurrency.IScheduler)} })} },System.Reactive.Concurrency.IScheduler)}

Qbservable.Start(IQbservableProvider, Expression) method

Defined in

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

Applies to

netstandard2.0

Overloads

  • 1. public static IQbservable<Unit> Start(this IQbservableProvider provider, Expression<Action> action)
  • 2. public static IQbservable<Unit> Start(this IQbservableProvider provider, Expression<Action> action, IScheduler scheduler)
  • 3. public static IQbservable<TResult> Start<TResult>(this IQbservableProvider provider, Expression<Func<TResult>> function)
  • 4. public static IQbservable<TResult> Start<TResult>(this IQbservableProvider provider, Expression<Func<TResult>> function, IScheduler scheduler)

1. Overload

public static IQbservable<Unit> Start(this IQbservableProvider provider, Expression<Action> action)

Summary: Invokes the action asynchronously, surfacing the result through an observable sequence.

Parameters

NameTypeDescription
provider[IQbservableProvider](#Query provider used to construct the [IQbservable](# data source.
actionExpressionAction to run asynchronously.

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Remarks

-

The action is called immediately, not during the subscription of the resulting sequence.

-

Multiple subscriptions to the resulting sequence can observe the action's outcome.

Exceptions

TypeCondition
System.ArgumentNullExceptionaction is null.

2. Overload

public static IQbservable<Unit> Start(this IQbservableProvider provider, Expression<Action> action, IScheduler scheduler)

Summary: Invokes the action asynchronously on the specified scheduler, surfacing the result through an observable sequence.

Parameters

NameTypeDescription
provider[IQbservableProvider](#Query provider used to construct the [IQbservable](# data source.
actionExpressionAction to run asynchronously.
scheduler[IScheduler](#Scheduler to run the action on.

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Remarks

-

The action is called immediately, not during the subscription of the resulting sequence.

-

Multiple subscriptions to the resulting sequence can observe the action's outcome.

Exceptions

TypeCondition
System.ArgumentNullExceptionaction or scheduler is null.

3. Overload

public static IQbservable<TResult> Start<TResult>(this IQbservableProvider provider, Expression<Func<TResult>> function)

Summary: Invokes the specified function asynchronously, surfacing the result through an observable sequence.

Type parameters

NameDescription
TResultThe type of the result returned by the function.

Parameters

NameTypeDescription
provider[IQbservableProvider](#Query provider used to construct the [IQbservable](# data source.
functionExpression>Function to run asynchronously.

Returns: IQbservable -- An observable sequence exposing the function's result value, or an exception.

Remarks

-

The function is called immediately, not during the subscription of the resulting sequence.

-

Multiple subscriptions to the resulting sequence can observe the function's result.

Exceptions

TypeCondition
System.ArgumentNullExceptionfunction is null.

4. Overload

public static IQbservable<TResult> Start<TResult>(this IQbservableProvider provider, Expression<Func<TResult>> function, IScheduler scheduler)

Summary: Invokes the specified function asynchronously on the specified scheduler, surfacing the result through an observable sequence

Type parameters

NameDescription
TResultThe type of the result returned by the function.

Parameters

NameTypeDescription
provider[IQbservableProvider](#Query provider used to construct the [IQbservable](# data source.
functionExpression>Function to run asynchronously.
scheduler[IScheduler](#Scheduler to run the function on.

Returns: IQbservable -- An observable sequence exposing the function's result value, or an exception.

Remarks

-

The function is called immediately, not during the subscription of the resulting sequence.

-

Multiple subscriptions to the resulting sequence can observe the function's result.

Exceptions

TypeCondition
System.ArgumentNullExceptionfunction or scheduler is null.