Details
-
Task
-
Resolution: Done
-
Unknown
-
None
-
None
-
None
-
Fully Compatible
-
Not Needed
-
Description
For example:
// watch client filtering on database name
|
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>() |
.Match(x => x.DatabaseNamespace.DatabaseName.StartsWith("MyPrefix")); |
var changeStream = client.Watch(pipeline);
|
|
|
// watch client filtering on collection name
|
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>() |
.Match(x => x.CollectionNamespace.CollectionName.StartsWith("MyPrefix")); |
var changeStream = client.Watch(pipeline);
|
|
|
// watch database filtering on collection name
|
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>() |
.Match(x => x.CollectionNamespace.CollectionName.StartsWith("MyPrefix")); |
var changeStream = database.Watch(pipeline);
|
Attachments
Issue Links
- is related to
-
CSHARP-4645 WatchAsync() signatures are not consistent
-
- Closed
-