Class ForkableRecallSink<T>

Example

const forkable = new ForkableRecallSink<number>()
const writable = new WritableStream(forkable)
await fromCollection([1, 2, 3, 4, 5, 6, 7]).pipeTo(writable)
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