withLatestFrom

/**
 * 语法
 * @param {Observable} args
 * @return {Function}
 */
withLatestFrom(...args);

添加某个数据流中的最后一个值合并计算

动画示例

import { interval } from "rxjs";
import { take, withLatestFrom } from "rxjs/operators";
import { mapToCharacter } from "operators";

const source$ = interval(1000).pipe(take(7));
const notifier$ = interval(630).pipe(mapToCharacter(), take(5));
const result$ = source$.pipe(withLatestFrom(notifier$));

• 官方文档