@epikodelabs/streamix / skipUntil
Function: skipUntil()
skipUntil<
T,N>(notifier):Operator<T,T>
Defined in: projects/libraries/streamix/src/lib/operators/skipUntil.ts:33
Skip source values until a notifier emits.
skipUntil suppresses (drops) source values until the provided notifier produces its first emission. After the notifier emits, subsequent source values are forwarded normally.
Values suppressed before the gate opens are yielded with dropped: true so that backpressure is released and downstream operators can observe the suppressed emissions.
Important details:
- Notifier completion without emission: if the notifier completes without emitting, the operator remains closed and continues to drop source values.
- Error propagation: errors from either the notifier or source are propagated to the output and will terminate the subscription.
Type Parameters
T
T = any
Source/output value type.
N
N = any
Notifier value type (ignored by this operator).
Parameters
notifier
A Stream<N> or Promise<N> that opens the gate when it emits.
Stream<N> | Promise<N>
Returns
Operator<T, T>
An Operator<T, T> that drops source values until the notifier emits.