Skip to content

IStreamQueueCheckpointerFactory.Create(string, CancellationToken)

Create(string, CancellationToken)

virtual
View source
public virtual 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.