RxJS：如何在一个流中组合两个流，以一个流的速率触发事件，但使用另一个流中的最新值？

Question

我对RX非常陌生。这是我试图解决的一个问题的简单模型。它看起来很容易，但我很难找到合适的运算符（或以其他方式操作流）来解决它。

假设我们有两条流。一个是频繁地释放值；另一种情况则远没有那么严重。我们希望每次第二个可观测对象发出一个值时，获取该点另一个可观测对象发出的最新值，并对其进行处理。

非工作示例：

let stream1 = Rx.Observable
    .interval(100);

let stream2 = Rx.Observable
    .interval(2000)
  .combineLatest(stream1, (stream2Value, stream1Value) => stream1Value)
  .do((stream1Value) => console.log('value:', stream1Value));

stream2.subscribe();

上面片段的问题是，它会等到从stream 2发出的第一个值，然后开始以stream 1的频率发出一个事件流。我想要的是得到一个流，它将以stream 2的速率触发事件，但将在stream 2触发时发出stream 1发出的最新值。听起来好像我需要stream 1成为一个行为主体，这样我就可以在stream 2触发时访问它的最后一个值......但也许有一个更简单的解决方案？

Answer 1

您可以使用withLatestFrom来执行此操作：

let stream1 = Rx.Observable
  .interval(100);

let stream2 = Rx.Observable
  .interval(2000)
  .withLatestFrom(stream1, (stream2Value, stream1Value) => stream1Value)
  .do((stream1Value) => console.log("value:", stream1Value));

stream2.subscribe();

html lang-html prettyprint-override"><script src="https://npmcdn.com/@reactivex/rxjs@5.0.3/dist/global/Rx.min.js"></script>