重复发射一个主题

编程问答 2022-05-03

问题描述

我不明白为什么下面的 BehavIoUrSeubject 没有发出 3 次

const numbers = [1,2,3,4]
const urls$ = new BehaviorSubject<number[]>(numbers)

urls$.pipe(repeat(3)).subscribe(console.log)

另外，下面的语义是什么？

urls$.pipe(switchMap(arr => from(arr)),repeat(3)).subscribe(console.log)

我也希望重复三遍，但唯一可行的情况是

urls$.pipe(switchMap(arr => from(arr).pipe(repeat(3)))).subscribe(console.log)

解决方法

根据repeat运算符的定义，

repeat(count) 操作符返回一个 Observable，它会在源流完成时重新订阅源流，最多 count 次。

因此，在这种情况下，source$ 是 urls$ 需要完成以便重复可以执行，但 urls$ 是一个行为主体，一旦你用 urls$.complete() 表示行为主体完成，你就赢了'无法接收订阅中的任何内容。因此，如果您想拥有行为主体发出的值，则不能使用 repeat 运算符。

现在我们如何解决这个问题？

expand 运算符来拯救我们。 [expand][1] 递归地投影源 observable 发出的值。使用 expand & take，我们将能够达到预期的结果。

const numbers = [1,2,3,4];
const urls$ = new BehaviorSubject<number[]>(numbers);

urls$
  .pipe(expand(result => urls$),take(3))
  .subscribe(console.log);
repeatrepeatrxjsrxjssubjectswitchmaptypescripttypescripttypescript