Class ForkableRecallStream<T>

An extension to the :class that immediately queues the last received chunk to any fork.

See

ForkableRecallSink

Example

const forkable = new ForkableRecallStream<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 last thing that was emitted.

await forkable.fork().pipeTo(write(console.info))
// 7
Copy