filter

述語関数に基づいてソース Observable から発行される値をフィルタリングします。 述語を満たす値のみが結果の Observable から発行されます。

Marble Diagram

filter(x => x % 2 === 0)

使用例

//  Timeline:
//
//  num$          1     2     3     4     5     6
//  even$               2           4           6
//
//  Explanation:
//  - filter passes through only values that satisfy the predicate
//  - Only even numbers (2, 4, 6) are emitted

const num$ = source<number>();

const even$ = num$.pipe(filter((x) => x % 2 === 0));

const valueHistory: number[] = [];

even$.subscribe((x) => {
    valueHistory.push(x);
});

num$.next(1); // nothing logged

num$.next(2); // logs: 2

assert.deepStrictEqual(valueHistory, [2]);

num$.next(3); // nothing logged

num$.next(4); // logs: 4

assert.deepStrictEqual(valueHistory, [2, 4]);

num$.next(5);

num$.next(6);

assert.deepStrictEqual(valueHistory, [2, 4, 6]);

View source on GitHub