-record(event_stream, {
    read_all :: fun(() -> list(aion_client@stream:stream_item(any())))
}).