Container.ChangeFeedStreamHandlerWithManualCheckpoint Delegado

Definición

Espacio de nombres:

Microsoft.Azure.Cosmos

Ensamblado:

Microsoft.Azure.Cosmos.Client.dll

Paquete:

Microsoft.Azure.Cosmos v3.39.0

Source:

Container.cs

Delegar para recibir los cambios dentro de una ejecución con punto ChangeFeedProcessor de control manual.

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 

Parámetros

context

ChangeFeedProcessorContext

Contexto relacionado con los cambios.

changes

Stream

Los cambios que se produjeron.

checkpointAsync

Func<Task>

Tarea que representa un punto de control asincrónico en el progreso de una concesión.

cancellationToken

CancellationToken

Token de cancelación que representa el estado de cancelación actual de la ChangeFeedProcessor instancia.

Valor devuelto

Task

que Task representa la operación asincrónica que se va a realizar con los cambios.

Ejemplos

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

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