changeStreamSpecificOptions method
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!,
};