Method WatchAsync
WatchAsync<TResult>(PipelineDefinition<ChangeStreamDocument<TDocument>, TResult>, ChangeStreamOptions, CancellationToken)
Watches changes on the collection.
Task<IChangeStreamCursor<TResult>> WatchAsync<TResult>(PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline, ChangeStreamOptions options = null, CancellationToken cancellationToken = default)
Parameters
pipeline
PipelineDefinition <ChangeStream <TDocument>, TResult>Document The pipeline.
options
ChangeStream Options The options.
cancellationToken
CancellationToken The cancellation token.
Returns
- Task<IChange
Stream <TResult>>Cursor A change stream.
Type Parameters
TResult
The type of the result.
WatchAsync<TResult>(IClientSessionHandle, PipelineDefinition<ChangeStreamDocument<TDocument>, TResult>, ChangeStreamOptions, CancellationToken)
Watches changes on the collection.
Task<IChangeStreamCursor<TResult>> WatchAsync<TResult>(IClientSessionHandle session, PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline, ChangeStreamOptions options = null, CancellationToken cancellationToken = default)
Parameters
session
IClientSession Handle The session.
pipeline
PipelineDefinition <ChangeStream <TDocument>, TResult>Document The pipeline.
options
ChangeStream Options The options.
cancellationToken
CancellationToken The cancellation token.
Returns
- Task<IChange
Stream <TResult>>Cursor A change stream.
Type Parameters
TResult
The type of the result.