Skip to content

VolatileJournalStorage.ReadAsync(IJournalStorageConsumer, CancellationToken)

ReadAsync(IJournalStorageConsumer, CancellationToken)

View source
public 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.