rxjs - 从多个来源获取最后发出的对象

Question

更具体地说，我不需要发射对象的数组。我想要任一源发出的最后一个对象。

目前，它是这样工作的

.withLatestFrom(subject1, subject2)
.switchMap([val1, val2]) => {...}

我想要的是

.withLatestFrom(subject1, subject2)
.switchMap(latestVal) => {...}

避免可能的 x=y 问题。我有两个科目。主题 1 和主题 2。

如果 subject2 发出了任何值，该值将始终胜过 subject1。在我的用例中，一旦主题 2 开始发出，这个特定模块将忽略主题 1。但是主题 1 将在其他地方使用。

但我想要一种方法将这两个主题作为源提供，并获取最后发出的值，或者主题 2 的最后一个值(如果它不为空)。如果主题 2 为空，则从主题 1 获取最后一个值。

Answer 1

这是一个我认为可以满足您要求的示例:

const first = Rx.Observable.interval(1000).map(x => `first (${x})`);
const second = Rx.Observable.interval(2000).map(x => `second (${x})`);

Rx.Observable.merge(
  first.takeUntil(second),
  second
)
.subscribe(
  x => { console.log('next: ', x); },
  null,
  () => { console.log('complete'); }
);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.5.5/Rx.min.js"></script>

takeUntil 将导致“第一个”可观察对象在“第二个”可观察对象第一次发出时停止为该订阅发出值。