Skip to main content

filterObservablePipe

Alternative: filter$$$

Inlined: filterObservable, filter$$

Types​

function filterObservablePipe<GValue>(
  filterFunction: IFilterFunctionGeneric<GValue>,
): IObservablePipe<GValue, GValue>

Definition​

This pipe filters items emitted by the source Observable by only emitting those that satisfy a specified predicate filterFunction.

The RxJS equivalent is filter.

Diagram​

Algorithm​

OUTfilterObservablePipe(filterFunction)observableOUTfilterObservablePipe(filterFunction)observablealt[if filterFunction(value)returns true][else discard value]valuevaluenever

Example​

OUTfilterObservablePipe(x => x % 2 === 1)observableOUTfilterObservablePipe(x => x % 2 === 1)observable0112334

Example​

Emit only the odd values​

const subscribe = pipe$$(of(0, 1, 2, 3, 4), [
  filter$$$(x => x % 2 === 1),
]);

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

Output:

1
3