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