IStreamQueueCheckpointer<TCheckpoint>.FlushAsync(CancellationToken)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IStreamQueueCheckpointer<TCheckpoint>
5. Methods
6. FlushAsync(CancellationToken)

Markdown

FlushAsync(CancellationToken)

virtual

View source

public virtual Task FlushAsync(CancellationToken cancellationToken)

Flushes any pending checkpoint to persistent storage, ensuring the latest offset is durably saved. Called during shutdown or rebalancing to prevent message replay on restart.

Parameters

cancellationTokenCancellationToken

The cancellation token.

Returns

A System.Threading.Tasks.Task representing the flush operation.