First tentative steps toward a robust MQTT API based on RX