Skip to content

JournalStorageConsumerExtensions.Read(IJournalStorageConsumer, IEnumerable<ReadOnlyMemory<byte>>, IJournalMetadata?, bool)

Read(IJournalStorageConsumer, IEnumerable<ReadOnlyMemory<byte>>, IJournalMetadata?, bool)

staticextension
View source
public static void Read(this IJournalStorageConsumer consumer, IEnumerable<ReadOnlyMemory<byte>> segments, IJournalMetadata? metadata, bool complete)
Supplies ordered segments to consumer.

Parameters

consumerIJournalStorageConsumer
The journal storage consumer.
segmentsIEnumerable<ReadOnlyMemory<byte>>
The ordered bytes to read.
metadataIJournalMetadata?
The metadata associated with the journal data being read, or null if no metadata is available.
completebool
Whether to notify the consumer that no more data will be supplied. If false, the consumer must read all supplied bytes.