query method

Future<MongoReplyMessage> query(
  1. MongoMessage queryMessage
)

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