query method
Implementation
Future<MongoReplyMessage> query(MongoMessage queryMessage) {
var completer = Completer<MongoReplyMessage>();
if (!_closed) {
_replyCompleters[queryMessage.requestId] = completer;
_pendingQueries.add(queryMessage.requestId);
_log.fine(() => 'Query $queryMessage');
_sendQueue.addLast(queryMessage);
_sendBuffer();
} else {
completer.completeError(const ConnectionException(
'Invalid state: Connection already closed.'));
}
return completer.future;
}