ChangeStreamOperation constructor

ChangeStreamOperation(
  1. Object pipeline, {
  2. DbCollection? collection,
  3. Db? db,
  4. int? batchSize,
  5. String? hint,
  6. Map<String, Object>? hintDocument,
  7. ChangeStreamOptions? changeStreamOptions,
  8. Map<String, Object>? rawOptions,
})

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()
  });
}