RxJS中多个流的同步处理

Question

假设我们有两个可观测的物体(可观测的A和可观测的B)，它们都是随机发射的。我们不知道这些可观察到的物质发出的频率和方式。假设，当可观测的A发出一个值时，我想等到可观测的B发出一个值，然后以一个可观测的C返回它。基本上，每次可观测到的A发射，我希望它等待可观测的B发出，然后发出在可观测的C中发出的值。我想忽略B流中发出的所有其他值。我能用什么运营商来实现这一点呢？

Answer 1

也许skipUntil过滤器和withLatestFrom操作符可以帮助你。skipUntil忽略在B中发出的值，直到A发出。

就像这样：

    var test$ = B$.pipe(skipUntil(A$))
    var C$ = test$.pipe(
      withLatestFrom(A$), 
      map(([a,b]) => {
        return a
      }))