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