Udostępnij za pośrednictwem


Container.ChangeFeedHandlerWithManualCheckpoint<T> Delegate

Definition

Delegate to receive the changes within a ChangeFeedProcessor execution with manual checkpoint.

public delegate System.Threading.Tasks.Task Container.ChangeFeedHandlerWithManualCheckpoint<T>(ChangeFeedProcessorContext context, IReadOnlyCollection<T> changes, Func<Task> checkpointAsync, CancellationToken cancellationToken);
type Container.ChangeFeedHandlerWithManualCheckpoint<'T> = delegate of ChangeFeedProcessorContext * IReadOnlyCollection<'T> * Func<Task> * CancellationToken -> Task
Public Delegate Function Container.ChangeFeedHandlerWithManualCheckpoint(Of T)(context As ChangeFeedProcessorContext, changes As IReadOnlyCollection(Of T), checkpointAsync As Func(Of Task), cancellationToken As CancellationToken) As Task 

Type Parameters

T

Parameters

context
ChangeFeedProcessorContext

The context related to the changes.

changes
IReadOnlyCollection<T>

The changes that happened.

checkpointAsync
Func<Task>

A task representing an asynchronous checkpoint on the progress of a lease.

cancellationToken
CancellationToken

A cancellation token representing the current cancellation status of the ChangeFeedProcessor instance.

Return Value

A Task representing the asynchronous operation that is going to be done with the changes.

Examples

(ChangeFeedProcessorContext context, IReadOnlyCollection<T> changes, Func<Task> checkpointAsync, CancellationToken cancellationToken) =>
{
    // consume changes

    // On certain condition, we can checkpoint
    await checkpointAsync();
}

Applies to