combine (combineLatest)

複数の Observable を、それぞれの最新値の配列を発行する単一の Observable に結合します。 いずれかのソース Observable が発行するたびに発行しますが、すべてのソースが少なくとも1回発行した後に限ります。

Marble Diagram

combine

使用例

//  Timeline:
//
//  name$     "Alice"                 "Bob"
//  age$                25                        30
//  user$               ["Alice",25]  ["Bob",25]  ["Bob",30]
//
//  Explanation:
//  - combine waits for all sources to emit at least once
//  - Then emits the latest value from all sources whenever any source emits
//  - Always emits an array with the latest values from each source

const name$ = source<string>();

const age$ = source<number>();

const user$ = combine([name$, age$]);

const userHistory: (readonly [string, number])[] = [];

user$.subscribe(([name_, age]) => {
    userHistory.push([name_, age]);
});

name$.next('Alice'); // nothing logged (age$ hasn't emitted yet)

assert.deepStrictEqual(userHistory, []);

age$.next(25); // logs: { name: 'Alice', age: 25 }

assert.deepStrictEqual(userHistory, [['Alice', 25]]);

name$.next('Bob'); // logs: { name: 'Bob', age: 25 }

assert.deepStrictEqual(userHistory, [
    ['Alice', 25],
    ['Bob', 25],
]);

age$.next(30); // logs: { name: 'Bob', age: 30 }

assert.deepStrictEqual(userHistory, [
    ['Alice', 25],
    ['Bob', 25],
    ['Bob', 30],
]);

View source on GitHub