RxJS

Question

在 RxJS 中，我有时会遇到这样的情况，当我有一个 Observable 发射时，我想 'trigger' 另一个 Observable 的发射。

例如：

subject1$.subscribe(result => {/**/})

//...later 

someObservable$.subscribe(result => {
  subject1$.next(result);
});

我宁愿避免使用两个流，但我不知道是否有一个 pipable 运算符可以用来 'pipe' 从 someObservable$ 到 subject1$ 的任何遗漏。

Answer 1

A Subject 既是 Observable 又是 Observer。

tap 运算符接受 Observer 作为其参数。

subscribe 函数也接受 Observer 作为其参数。

把所有这些东西放在一起，你可能会看到这样的东西

subject1$.subscribe(result => {/**/})

//...later 

someObservable$.tap(subject1$).subscribe();

// or

someObservable$.subscribe(subject1$);

RxJS - 如何 'pipe' 一个 Observable 的结果到一个流中的另一个主题