如何在RxJS中设定时间间隔后对整个流执行forEach

import { interval } from 'rxjs';
import { take } from 'rxjs/operators';

const source$ = interval(1000); // 每隔1秒发出一个整数

const limitedSource$ = source$.pipe(take(5)); // 限制流执行5次

limitedSource$.subscribe(
  value => {
    // 在这里执行对整个流的操作
    console.log(value);
  },
  error => {
    // 处理错误情况
    console.error(error);
  },
  () => {
    // 流执行完成后的回调函数
    console.log('流执行完成');
  }
);