INNER CODE UNIT · Python

init_app

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

    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,
        qos: int = 0,
        no_local: bool = False,
        retain_as_published: bool = False,
        retain_handling_options: int = 0,

View source record →