Skip to content

,ReactiveUI.Primitives.Async.IObservableAsync{--1})} ,ReactiveUI.Primitives.Async.IObservableAsync{--1},ReactiveUI.Primitives.Async.TakeUntilOptions)} ,ReactiveUI.Primitives.Async.IObservableAsync{--1},System.Threading.CancellationToken)} ,ReactiveUI.Primitives.Async.IObservableAsync{--1},ReactiveUI.Primitives.Async.TakeUntilOptions,System.Threading.CancellationToken)} ,System.Threading.Tasks.Task)} ,System.Threading.Tasks.Task,ReactiveUI.Primitives.Async.TakeUntilOptions)} ,System.Threading.Tasks.Task,System.Threading.CancellationToken)} ,System.Threading.Tasks.Task,ReactiveUI.Primitives.Async.TakeUntilOptions,System.Threading.CancellationToken)} ,System.Threading.CancellationToken)} ,System.Func{--0,System.Boolean})} ,System.Func{--0,System.Boolean},System.Threading.CancellationToken)} ,System.Func{--0,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask{System.Boolean}})} ,System.Func{--0,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask{System.Boolean}},System.Threading.CancellationToken)} ,ReactiveUI.Primitives.Async.CompletionSignalDelegate)} ,ReactiveUI.Primitives.Async.CompletionSignalDelegate,ReactiveUI.Primitives.Async.TakeUntilOptions)} ,ReactiveUI.Primitives.Async.CompletionSignalDelegate,System.Threading.CancellationToken)} ,ReactiveUI.Primitives.Async.CompletionSignalDelegate,ReactiveUI.Primitives.Async.TakeUntilOptions,System.Threading.CancellationToken)}

SignalAsyncExtensions.TakeUntil(IObservableAsync, IObservableAsync) method

Defined in

Type: SignalAsyncExtensions Namespace: ReactiveUI.Primitives.Async Assembly: ReactiveUI.Primitives.Async.dll

Applies to

net10.0, net10.0, net10.0-desktop1.0, net10.0-desktop1.0, net10.0-browserwasm1.0, net10.0-browserwasm1.0, net9.0, net9.0, net9.0-desktop1.0, net9.0-desktop1.0, net9.0-browserwasm1.0, net9.0-browserwasm1.0, net8.0, net8.0, net8.0-ios17.5, net8.0-macos14.5, net8.0-macos14.5, net8.0-macos14.2, net8.0-macos14.2, net8.0-maccatalyst17.5, net8.0-maccatalyst17.5, net8.0-tvos17.2, net8.0-tvos17.2, net8.0-ios17.5, netstandard2.1, netstandard2.1, net481, net462, net462, net481

Overloads

  • 1. public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other)
  • 2. public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other, TakeUntilOptions? options)
  • 3. public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other, CancellationToken cancellationToken)
  • 4. public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other, TakeUntilOptions? options, CancellationToken cancellationToken)
  • 5. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task) where T : notnull
  • 6. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task, TakeUntilOptions? options)
  • 7. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task, CancellationToken cancellationToken) where T : notnull
  • 8. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task, TakeUntilOptions? options, CancellationToken cancellationToken)
  • 9. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CancellationToken cancellationToken)
  • 10. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, bool> predicate)
  • 11. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, bool> predicate, CancellationToken cancellationToken)
  • 12. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, CancellationToken, ValueTask<bool>> asyncPredicate)
  • 13. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, CancellationToken, ValueTask<bool>> asyncPredicate, CancellationToken cancellationToken)
  • 14. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal) where T : notnull
  • 15. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal, TakeUntilOptions? options)
  • 16. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal, CancellationToken cancellationToken) where T : notnull
  • 17. public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal, TakeUntilOptions? options, CancellationToken cancellationToken)

1. Overload

public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other)

View source

Type parameters

NameDescription
T--
TOther--

Parameters

NameTypeDescription
source[IObservableAsync](#--
other[IObservableAsync](#--

Returns: IObservableAsync

2. Overload

public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other, TakeUntilOptions? options)

View source

Type parameters

NameDescription
T--
TOther--

Parameters

NameTypeDescription
source[IObservableAsync](#--
other[IObservableAsync](#--
options[TakeUntilOptions?](#--

Returns: IObservableAsync

3. Overload

public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--
TOther--

Parameters

NameTypeDescription
source[IObservableAsync](#--
other[IObservableAsync](#--
cancellationTokenCancellationToken--

Returns: IObservableAsync

4. Overload

public static IObservableAsync<T> TakeUntil<T, TOther>(this IObservableAsync<T> source, IObservableAsync<TOther> other, TakeUntilOptions? options, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--
TOther--

Parameters

NameTypeDescription
source[IObservableAsync](#--
other[IObservableAsync](#--
options[TakeUntilOptions?](#--
cancellationTokenCancellationToken--

Returns: IObservableAsync

5. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task) where T : notnull

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
taskTask--

Returns: IObservableAsync

6. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task, TakeUntilOptions? options)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
taskTask--
options[TakeUntilOptions?](#--

Returns: IObservableAsync

7. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task, CancellationToken cancellationToken) where T : notnull

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
taskTask--
cancellationTokenCancellationToken--

Returns: IObservableAsync

8. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Task task, TakeUntilOptions? options, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
taskTask--
options[TakeUntilOptions?](#--
cancellationTokenCancellationToken--

Returns: IObservableAsync

9. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
cancellationTokenCancellationToken--

Returns: IObservableAsync

10. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, bool> predicate)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
predicateFunc--

Returns: IObservableAsync

11. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, bool> predicate, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
predicateFunc--
cancellationTokenCancellationToken--

Returns: IObservableAsync

12. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, CancellationToken, ValueTask<bool>> asyncPredicate)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
asyncPredicateFunc>--

Returns: IObservableAsync

13. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, Func<T, CancellationToken, ValueTask<bool>> asyncPredicate, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
asyncPredicateFunc>--
cancellationTokenCancellationToken--

Returns: IObservableAsync

14. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal) where T : notnull

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
stopSignal[CompletionSignalDelegate](#--

Returns: IObservableAsync

15. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal, TakeUntilOptions? options)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
stopSignal[CompletionSignalDelegate](#--
options[TakeUntilOptions?](#--

Returns: IObservableAsync

16. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal, CancellationToken cancellationToken) where T : notnull

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
stopSignal[CompletionSignalDelegate](#--
cancellationTokenCancellationToken--

Returns: IObservableAsync

17. Overload

public static IObservableAsync<T> TakeUntil<T>(this IObservableAsync<T> source, CompletionSignalDelegate stopSignal, TakeUntilOptions? options, CancellationToken cancellationToken)

View source

Type parameters

NameDescription
T--

Parameters

NameTypeDescription
source[IObservableAsync](#--
stopSignal[CompletionSignalDelegate](#--
options[TakeUntilOptions?](#--
cancellationTokenCancellationToken--

Returns: IObservableAsync