generateQueryMessage method

@override MongoQueryMessage generateQueryMessage()

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