Container.ChangeFeedStreamHandlerWithManualCheckpoint Délégué

Définition

Espace de noms:

Microsoft.Azure.Cosmos

Assembly:

Microsoft.Azure.Cosmos.Client.dll

Paquet:

Microsoft.Azure.Cosmos v3.39.0

Source:

Container.cs

Déléguer pour recevoir les modifications dans une ChangeFeedProcessor exécution avec un point de contrôle manuel.

public delegate System.Threading.Tasks.Task Container.ChangeFeedStreamHandlerWithManualCheckpoint(ChangeFeedProcessorContext context, Stream changes, Func<Task> checkpointAsync, CancellationToken cancellationToken);

type Container.ChangeFeedStreamHandlerWithManualCheckpoint = delegate of ChangeFeedProcessorContext * Stream * Func<Task> * CancellationToken -> Task

Public Delegate Function Container.ChangeFeedStreamHandlerWithManualCheckpoint(context As ChangeFeedProcessorContext, changes As Stream, checkpointAsync As Func(Of Task), cancellationToken As CancellationToken) As Task 

Paramètres

context

ChangeFeedProcessorContext

Contexte lié aux modifications.

changes

Stream

Les modifications qui se sont produites.

checkpointAsync

Func<Task>

Tâche représentant un point de contrôle asynchrone sur la progression d’un bail.

cancellationToken

CancellationToken

Jeton d’annulation représentant la status d’annulation actuelle du ChangeFeedProcessor instance.

Valeur renvoyée

Task

Task représentant l’opération asynchrone qui va être effectuée avec les modifications.

Exemples

(ChangeFeedProcessorContext context, Stream stream, Func<Task> checkpointAsync, CancellationToken cancellationToken) =>
{
    // consume stream

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