asyncio-paho 0.1.0

A Paho MQTT client supporting asyncio loop without additional setup.

Asynchronous I/O (asyncio) Paho MQTT client

A Paho MQTT client supporting asyncio loop without additional setup. Forget about configuring the Paha network-loop. The client can almost be used as a drop-in replacement for Paho Client. The asyncio loop is automatically configured when you connect. You should use connect_async to connect to avoid blocking.

client = AsyncioPahoClient()
client.connect_async("mqtt.eclipseprojects.io")

# do mqtt stuff

client.Disconnect()

Asynchronous Context Manager

The client is an Asynchronous Context Manager and can be used with the Python with statement to atomatically disconnect and clean up.

async with AsyncioPahoClient() as client:
    client.connect_async("mqtt.eclipseprojects.io")
    
    # do mqtt stuff - client.Disconnect() is called when exiting context.