Skip to content

GrainStreamQueueCheckpointerFactory.Create(string, CancellationToken)

Create(string, CancellationToken)

View source
public Task<IStreamQueueCheckpointer<string>> Create(string partition, CancellationToken cancellationToken)
Creates a stream checkpointer for the specified partition.

Parameters

partitionstring
The partition.
cancellationTokenCancellationToken
The cancellation token.

Returns

The stream checkpointer.