@epikodelabs/streamix / skipUntil
Function: skipUntil()
skipUntil<
T,N>(notifier):Operator<T,T>
Defined in: projects/libraries/streamix/src/lib/operators/skipUntil.ts:32
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.
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.
Common uses:
- Ignore initial values until a readiness signal arrives.
- Wait for user interaction before processing inputs.
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.