queryMessage method

Future<MongoReplyMessage> queryMessage(
  1. MongoMessage queryMessage, {
  2. Connection? connection,
})

Implementation

Future<MongoReplyMessage> queryMessage(MongoMessage queryMessage,
    {Connection? connection}) {
  return Future.sync(() {
    if (state != State.open) {
      throw MongoDartError('Db is in the wrong state: $state');
    }

    connection ??= masterConnection;

    return connection!.query(queryMessage);
  });
}