Привет, можно как-то элегантнее сделать reset накопленного состоянии concatMap? в данном

Question

Привет, можно как-то элегантнее сделать reset накопленного состоянии concatMap? в данном

решении repeat относится ко всему выше, не только к takeUntil,
.pipe(
// can’t complete there
concatMap(el => of(el).pipe(delay(1000))),
// workaround
takeUntil(concatMapreset.asObservable()),
repeat(),
takeUntil(streamDone.asObservable())
)
stackblitz тык