JournalStorageConsumerExtensions

1. Documentation
2. API reference
3. Microsoft.Orleans.Journaling
4. JournalStorageConsumerExtensions

class

Namespace: Orleans.Journaling

NuGetSourceMarkdown

Helper methods for reading journal storage data.

public static class JournalStorageConsumerExtensions

Methods

• Complete(IJournalStorageConsumer, IJournalMetadata?) Notifies consumer that no more data will be supplied.
• Read(IJournalStorageConsumer, IEnumerable<ReadOnlyMemory<byte>>, IJournalMetadata?, bool) Supplies ordered segments to consumer.
• Read(IJournalStorageConsumer, ReadOnlyMemory<byte>, IJournalMetadata?, bool) Supplies input to consumer.
• Read(IJournalStorageConsumer, ReadOnlySequence<byte>, IJournalMetadata?, bool) Supplies input to consumer.
• ReadAsync(IJournalStorageConsumer, Stream, IJournalMetadata?, CancellationToken) Reads all bytes from input and incrementally supplies them to consumer.
• ReadAsync(IJournalStorageConsumer, Stream, IJournalMetadata?, bool, CancellationToken) Reads all bytes from input and incrementally supplies them to consumer.