Class SkipUntilOperator

Namespace

RxSharp.Operators

Assembly

RxSharp.dll

Extension methods implementing the skipUntil operator.

public static class SkipUntilOperator

Inheritance

System.Object

SkipUntilOperator

Methods

SkipUntil<T, TNotifier>(Observable<T>, Observable<TNotifier>)

Skips values from source until notifier emits its first value, at which point every value after that (including ones emitted by source after the switch) is forwarded. The inverse of TakeUntil<T, TNotifier>(Observable<T>, Observable<TNotifier>).

public static Observable<T> SkipUntil<T, TNotifier>(this Observable<T> source, Observable<TNotifier> notifier)

Parameters

source Observable<T>

The source sequence to skip values from.

notifier Observable<TNotifier>

The observable whose first emitted value causes the output to start forwarding source's values.

Returns

Observable<T>

An observable that skips source's values until notifier emits, then forwards the rest.

Type Parameters

T

The type of values emitted by source and by the output.

TNotifier

The type of values emitted by notifier. Irrelevant to the output — only the fact that a value was emitted matters, not its contents.

Remarks

notifier is unsubscribed as soon as it emits its first value — later values it might emit have no further effect. If notifier completes without ever emitting a value, the output never forwards anything from source (though it still mirrors its completion or error). If notifier errors, that error is forwarded to the output, matching rxjs's own skipUntil — unlike TakeUntil<T, TNotifier>(Observable<T>, Observable<TNotifier>), a notifier error is not silently ignored here.