changeStreamSpecificOptions method

Map<String, Object> changeStreamSpecificOptions()

These options mut be passed to the $changeStream key in the aggregate command

Implementation

Map<String, Object> changeStreamSpecificOptions() => <String, Object>{
      if (resumeAfter != null) keyResumeAfter: resumeAfter!,
      if (startAfter != null) keyStartAfter: startAfter!,
      if (fullDocument != null) keyFullDocument: fullDocument!,
      if (maxAwaitTimeMS != null) keyMaxAwaitTimeMS: maxAwaitTimeMS!,
      if (startAtOperationTime != null)
        keyStartAtOperationTime: startAtOperationTime!,
    };