Skip to content

)} ,System.Reactive.Concurrency.IScheduler)} ,System.Object)} ,System.Object,System.Reactive.Concurrency.IScheduler)} ,System.Threading.CancellationToken)} ,System.Threading.CancellationToken,System.Reactive.Concurrency.IScheduler)} ,System.Threading.CancellationToken,System.Object)} ,System.Threading.CancellationToken,System.Object,System.Reactive.Concurrency.IScheduler)}

TaskObservableExtensions.ToTask(IObservable) method

Defined in

Type: TaskObservableExtensions Namespace: System.Reactive.Threading.Tasks 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 Task<TResult> ToTask<TResult>(this IObservable<TResult> observable)
  • 2. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, IScheduler scheduler)
  • 3. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, object? state)
  • 4. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, object? state, IScheduler scheduler)
  • 5. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken)
  • 6. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, IScheduler scheduler)
  • 7. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, object? state)
  • 8. public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, object? state, IScheduler scheduler)

1. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--

Returns: Task

2. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, IScheduler scheduler)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
scheduler[IScheduler](#--

Returns: Task

3. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, object? state)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
stateobject?--

Returns: Task

4. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, object? state, IScheduler scheduler)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
stateobject?--
scheduler[IScheduler](#--

Returns: Task

5. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
cancellationTokenCancellationToken--

Returns: Task

6. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, IScheduler scheduler)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
cancellationTokenCancellationToken--
scheduler[IScheduler](#--

Returns: Task

7. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, object? state)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
cancellationTokenCancellationToken--
stateobject?--

Returns: Task

8. Overload

public static Task<TResult> ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, object? state, IScheduler scheduler)

Type parameters

NameDescription
TResult--

Parameters

NameTypeDescription
observableIObservable--
cancellationTokenCancellationToken--
stateobject?--
scheduler[IScheduler](#--

Returns: Task