generateQueryMessage method
Implementation
@override
MongoQueryMessage generateQueryMessage() {
if (collection == null) {
throw MongoDartError('Collection required');
}
return DbCommand(
db,
DbCommand.SYSTEM_COMMAND_COLLECTION,
MongoQueryMessage.OPTS_NO_CURSOR_TIMEOUT,
0,
-1,
{
'aggregate': collection!.collectionName,
'pipeline': pipeline,
'cursor': cursorOptions,
'allowDiskUse': allowDiskUse
},
null);
}