Container.ChangeFeedStreamHandlerWithManualCheckpoint 代理人

リファレンス

定義

名前空間:: Microsoft.Azure.Cosmos

アセンブリ:: Microsoft.Azure.Cosmos.Client.dll

パッケージ:: Microsoft.Azure.Cosmos v3.39.0

ソース:: Container.cs

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

手動チェックポイントを使用して、実行中の変更を ChangeFeedProcessor 受け取るデリゲート。

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

パラメーター

context: ChangeFeedProcessorContext

変更に関連するコンテキスト。

changes: Stream

発生した変更。

checkpointAsync: Func<Task>

リースの進行状況に関する非同期チェックポイントを表すタスク。

cancellationToken: CancellationToken

インスタンスの現在のキャンセル状態 ChangeFeedProcessor を表すキャンセルトークン。

戻り値

Task

Task変更で実行される非同期操作を表す。

例

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

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

適用対象