Skip to main content

takeWhileObservablePipe

Alternative: takeWhile$$$

Inlined: takeWhileObservable, takeWhile$$

Types​

function takeWhileObservablePipe<GValue>(
  predicate: ITakeWhileObservablePredicateFunction<GValue>,
): IObservablePipe<GValue, GValue>

Definition​

This pipe emits values sent by the source Observable so long as each value satisfies the given predicate, and then stops as soon as this predicate is not satisfied.

The RxJS equivalent is takeWhile.

Diagram​

Algorithm​

OUTtakeWhileObservablePipe(predicate)observableOUTtakeWhileObservablePipe(predicate)observablealt[if predicate(value) is true][else unsubscribe anddiscard value]valuevalueunsubscribe

Example​

OUTtakeWhileObservablePipe(x => x < 3)observableOUTtakeWhileObservablePipe(x => x < 3)observableopt[Hypothetical next values]11223unsubscribe42

Example​

Take values as long as they are lower than 3​

const subscribe = pipe$$(of(1, 2, 3, 4), [
  takeWhile$$$(x => x < 3),
]);

subscribe((value: number) => {
  console.log(value);
});

Output:

1
2