receiveMessage method

Future<void> receiveMessage(
  1. IBaseSession baseSession,
  2. Message msg
)

Implementation

Future<void> receiveMessage(IBaseSession baseSession, Message msg) async {
  String realm = baseSession.realm();
  if (!_realms.containsKey(realm)) {
    throw Exception("cannot process message for non-existent realm $realm");
  }

  await _realms[realm]?.receiveMessage(baseSession.id(), msg);
}