.pipe(concatMap(({ reset, obs }) => obs.pipe(map(({ data }) => ({ data, reset })))))
.subscribe({
next: ({ data, reset }) => {
.pipe(concatMap(({ reset, obs }) => obs.pipe(map(({ data }) => ({ data, reset })))))
.subscribe({
next: ({ data, reset }) => {