Sinks

This library considers a “sink” to be something to write to. IE, a WritableStream.

• expectTimeline
• ForkableStream
• ForkableRecallStream
• ForkableReplayStream
• toArray
• toIterable
• toIterator
• write

Combining implementations

You can combine a number of sink implmentations by using the SinkComposite.

new WritableStream(
  new SinkComposite([new ForkableRecallSink(), write(console.info)])
)