Container.ChangeFeedStreamHandlerWithManualCheckpoint Delegar

Referência

Definição

Namespace:: Microsoft.Azure.Cosmos

Assembly:: Microsoft.Azure.Cosmos.Client.dll

Pacote:: Microsoft.Azure.Cosmos v3.39.0

Origem:: Container.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

Delegar para receber as alterações dentro de uma ChangeFeedProcessor execução com ponto de verificação 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

O contexto relacionado às alterações.

changes: Stream

As alterações que aconteceram.

checkpointAsync: Func<Task>

Uma tarefa que representa um ponto de verificação assíncrono sobre o progresso de uma concessão.

cancellationToken: CancellationToken

Um token de cancelamento que representa o status de cancelamento atual da ChangeFeedProcessor instância.

Valor Retornado

Task

Um Task que representa a operação assíncrona que será feita com as alterações.

Exemplos

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

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

Aplica-se a

Partilhar via