INNER CODE UNIT · Python

mqtt_shutdown

sabuhish/fastapi-mqtt · fastapi_mqtt/fastmqtt.py:229

    async def mqtt_shutdown(self) -> None:
        """Final disconnection for MQTT client, for lifespan shutdown."""
        await self.client.disconnect()

    def init_app(self, fastapi_app) -> None:  # pragma: no cover
        """Add startup and shutdown event handlers for app without lifespan."""

        @fastapi_app.on_event("startup")
        async def startup() -> None:
            await self.mqtt_startup()

        @fastapi_app.on_event("shutdown")
        async def shutdown() -> None:
            await self.mqtt_shutdown()

    def subscribe(
        self,
        *topics,

View source record →