MQTT goes reactive