ChangeStreamOperation constructor
ChangeStreamOperation(})
Implementation
ChangeStreamOperation(super.pipeline,
{super.collection,
super.db,
int? batchSize,
super.hint,
super.hintDocument,
ChangeStreamOptions? changeStreamOptions,
super.rawOptions})
: super(
cursor: batchSize == null
? null
: <String, Object>{keyBatchSize: batchSize},
aggregateOptions: changeStreamOptions,
) {
pipeline.insert(0, <String, Object>{
if (changeStreamOptions == null)
aggregateChangeStream: <String, Object>{}
else
aggregateChangeStream: changeStreamOptions.changeStreamSpecificOptions()
});
}