registerForMessage method Null safety

  1. @override
void registerForMessage(
  1. MqttMessageType msgType,
  2. MessageCallbackFunction? callback
)
override

Registers for the receipt of messages when they arrive.

Implementation

@override
void registerForMessage(
    MqttMessageType msgType, MessageCallbackFunction? callback) {
  messageProcessorRegistry[msgType] = callback;
}