RXJS:组合两个流,但在第二个流发送事件后取消第一个流

看起来你可以用 merge 和 takeUntil :

merge(
  streamA$.pipe(
    takeUntil(streamB$)
  ),
  streamB$
)

什么时候? streamB$ 然后发射任何东西 streamA$ 将被忽略,因为 取到 将完成链。

如果我理解正确,您可以合并这两个流,并取第一个答案:

const interval1$ = interval(1000);
const interval2$ = interval(800);

const source1 = interval1$.pipe(
  map(x => { return { id: 1, value: x } }),
  take(5)
);
const source2 = interval2$.pipe(
  map(x => { return { id: 2, value: x } }),
  take(5)
);

const s = merge(source1, source2);

const subscribe = s.pipe(take(1)).subscribe(x => console.log(x));

这将打印第一个答案,在本例中,这是第二个流的第一个元素。