使用 rxjs 拆分数组并在完成时重新订阅

Question

我有一个数组，我在 rxjs 运算符（scan、concatMap、repeat、map）的帮助下将它拆分为一个延迟 5 毫秒的倍数块，我这样做了

这里：

(data: any[]) =>
from(
    Array.from({ length: Math.ceil(data.length / 5) }, (_v, k) => k + 1)
).pipe(
    scan((_acc, curr) => curr * 5, 0),
    map((index: number) => data.slice(index - 5, index)),
    concatMap((item) => of(item).pipe(delay(5000))),
    repeatWhen(_=> interval(5000))
);

如何在 Observable 完成时跳过（避免）额外的 5000 毫秒延迟（延迟、repeatWhen）。

如果我改用重复运算符，则会收到 超出最大调用堆栈大小 错误

Answer 1

import { from, of } from 'rxjs';
import { bufferCount, delay, concatMap } from 'rxjs/operators';

const people = new Array(100).fill({}).map((v, i) => {
  return {firstNname: 'firstName-' + i, lastName: 'lastName-'+i, id:i}
}
  )
const arraySource = from(people);

const subscribe = arraySource
.pipe(
  bufferCount(5),
  concatMap((array) => of(array).pipe(delay(5000)))
)
.subscribe(val => console.log(val));

Stackblitz