rxjs里面的concatAll中

请问 concatAll 里面缓存机制如何实现的？

举个例子

import { concatAll, interval, take, map } from 'rxjs'
const ho$ = interval(1000)
  .pipe(take(2))
  .pipe(
    map(x => interval(1500).pipe(map(y => x + ':' + y), take(2)))
  )

const concat$ = ho$.pipe(concatAll())
concat$.subscribe({
  next: value => console.log('concat:', value),
  complete: () => console.log('concat complete')
})

内部每个可观察对象至少需要3秒才能全部发送完毕值，而源可观察对象每隔1秒发送一个值，请问这个缓存机制内部是如何实现的？