rxjs - 如何在 Rxjs 中延迟序列发射

Question

我有一个可观察的:

  messages: string[] = ['a', 'b', 'c'];
  const source = from(messages)

你如何延迟它，所以当有人订阅它时，它会延迟 n 秒来发出项目？所以:

source.subscribe(i => console.log(i));
// output  ...n seconds... 'a' ...n seconds... 'b' ...n seconds... 'c'

Answer 1

您可以使用 zip 将流与间隔组合:

zip(
  from(['a', 'b', 'c', 'd']),
  interval(1000),
  (a, b) => a
)
.subscribe(console.log);

zip 会将每个流的第 n 个元素组合成一个数组。这就是我们使用选择器函数的方式:(a, b) => a。它确保只使用第一个流中的元素。 interval 流仅用于延迟发射。