EventHubCheckpointer.FlushAsync(CancellationToken)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubCheckpointer
5. Methods
6. FlushAsync(CancellationToken)

Markdown

FlushAsync(CancellationToken)

View source

public Task FlushAsync(CancellationToken cancellationToken)

Flushes any pending checkpoint to persistent storage. Awaits any in-progress save, then persists the latest offset if it has advanced beyond the last saved value.

Parameters

cancellationTokenCancellationToken

The cancellation token.