Skip to content

MQTTBaseParser

faststream.mqtt.parser.MQTTBaseParser #

Base parser for MQTT messages — shared parse + decode logic.

parse_message async #

parse_message(msg: Message) -> MQTTMessage
Source code in faststream/mqtt/parser.py 
18
19
async def parse_message(self, msg: zmqtt.Message) -> MQTTMessage:
    raise NotImplementedError

decode_message async #

decode_message(msg: StreamMessage[Any]) -> DecodedMessage
Source code in faststream/mqtt/parser.py 
21
22
async def decode_message(self, msg: "StreamMessage[Any]") -> "DecodedMessage":
    return decode_message(msg)