rxjs - 绅士，一个 RxJs 计时器，它等待进程在下一个间隔之前完成执行

Question

我想要一个每 x 毫秒运行一次的计时器/间隔，我将在间隔期间运行一些进程。

我需要什么？我希望计时器在触发下一个间隔之前等待我的进程完成，如何？

我是做动画的，如果有的间隔稍微长一点也没关系。只是想确保所有流程都已完成执行。

Answer 1

因此您希望延迟至少为 x 毫秒，但始终要等到进程完成:

const getProcess = () => {
  console.log('creating process...');
  return timer(500 + Math.random() * 1000); // mock process
};

const source = forkJoin(
  timer(1000),
  defer(() => getProcess())
).pipe(
  repeat(),
);

source.subscribe(() => console.log('sub'));

现场演示:https://stackblitz.com/edit/rxjs-jhvorc

timer() 将只发出一次并完成，而 forkJoin() 将保证两个源 Observables 在它发出之前完成。然后repeat()会再次订阅它的源并重复整个过程。