Class ForkableReplayStream<T>

An extension to the :class that immediately queues the entire contents of whatever has been previously consumed.

See

ForkableReplaySink

Example

const forkable = new ForkableReplayStream<number>()
await fromCollection([1, 2, 3, 4, 5, 6, 7]).pipeTo(forkable)
Copy

Now the stream has finished, if we fork from it we'll receive the entire events that were published to it.

await forkable.fork().pipeTo(write(console.info))
// 1
// 2
// 3
// 4
// 5
// 6
// 7
Copy