Method WatchAsync
WatchAsync(IMongoDatabase, ChangeStreamOptions, CancellationToken)
Watches changes on all collection in a database.
public static Task<IChangeStreamCursor<ChangeStreamDocument<BsonDocument>>> WatchAsync(this IMongoDatabase database, ChangeStreamOptions options = null, CancellationToken cancellationToken = default)
Parameters
database
IMongoDatabase The database.
options
ChangeStream Options The options.
cancellationToken
CancellationToken The cancellation token.
Returns
- Task<IChange
Stream <ChangeCursor Stream <BsonDocument Document >>> A change stream.
WatchAsync(IMongoDatabase, IClientSessionHandle, ChangeStreamOptions, CancellationToken)
Watches changes on all collection in a database.
public static Task<IChangeStreamCursor<ChangeStreamDocument<BsonDocument>>> WatchAsync(this IMongoDatabase database, IClientSessionHandle session, ChangeStreamOptions options = null, CancellationToken cancellationToken = default)
Parameters
database
IMongoDatabase The database.
session
IClientSession Handle The session.
options
ChangeStream Options The options.
cancellationToken
CancellationToken The cancellation token.
Returns
- Task<IChange
Stream <ChangeCursor Stream <BsonDocument Document >>> A change stream.