executeMessage method

void executeMessage(
  1. MongoMessage message,
  2. WriteConcern? writeConcern, {
  3. Connection? connection,
})

Implementation

void executeMessage(MongoMessage message, WriteConcern? writeConcern,
    {Connection? connection}) {
  if (state != State.open) {
    throw MongoDartError('DB is not open. $state');
  }

  connection ??= _masterConnectionVerified;

  writeConcern ??= _writeConcern;

  // ignore: deprecated_member_use_from_same_package
  connection.execute(message, writeConcern == WriteConcern.ERRORS_IGNORED);
}