Skip to content

IJournalStorage.ReadAsync(IJournalStorageConsumer, CancellationToken)

ReadAsync(IJournalStorageConsumer, CancellationToken)

abstract
public abstract ValueTask ReadAsync(IJournalStorageConsumer consumer, CancellationToken cancellationToken)
Reads all journal data belonging to this instance and sends it to consumer.

Parameters

consumerIJournalStorageConsumer
The consumer of ordered raw journal data. Chunk boundaries are not journal-entry boundaries.
cancellationTokenCancellationToken
The cancellation token.

Returns

A System.Threading.Tasks.ValueTask representing the operation.