如果在给定时间框架内没有发出值，rxjs会发出常量值

Question

我有一个可以观察到的，它周期性地发出一个值（它发出数组）。

我如何使它，如果有2秒没有值，应该发出一个常量值（例如一个空数组）？

Answer 1

这将取决于如何获得这些数组。但您始终可以使用setinterval将observable更新为自上次发射后每2秒发射一次。这将确保每个消息的最大窗口为2秒（但可以少得多）

例如：

const observable = new Observable(function subscribe(subscriber) {
  var interval;  
  function resetInterval() {
    clearInterval(interval);
    interval = setInterval(() => subscriber.next([]), 2_000);
  }

  resetInterval();

  const subject = webSocket("ws://localhost:8081");

  subject.subscribe(
    msg => { subscriber.next(msg); resetInterval(); }
    err => subscriber.error
    () => console.log('complete') // Called when connection is closed (for whatever reason).
  );
});

Answer 2

这样做的一种方法是使用switchmap创建一个发出2个项的可观察的：

1. 原始值
2. 延迟2000 ms后的空数组。

如果switchmap从源接收到另一个发射，它将创建一个新的内部可观察数组，而不会发射空数组。

const obs$ = source$.pipe(
    switchMap(source => {
      return concat(
        of(source), 
        of([]).pipe(delay(2000))
      );
    })
);

这是StackBlitz的样本。