StreamSource

In std/io.

abstract type StreamSource<T> : {DataSource, Stream<Message<T>>}

A log: Message<T>s in order, replayable within its retention.