class AggregateReader {

    public void readSnapshots(String aggregateId, long minSequenceNumber, long maxSequenceNumber, int maxResults,
                              Consumer<SerializedEvent> eventConsumer) {
        snapshotReader.streamByAggregateId(aggregateId, minSequenceNumber, maxSequenceNumber,
                                           maxResults > 0 ? maxResults : Integer.MAX_VALUE, eventConsumer);
    }

    public  AggregateReader(EventStorageEngine eventStorageEngine, SnapshotReader snapshotReader);

}