chore(deps): support faststream <0.8 (#132)

Author: Lancetnik

pyproject.toml

@@ -41,7 +41,7 @@ classifiers = [
 
 dependencies = [
     "taskiq>=0.12.1,<0.13.0",
-    "faststream>=0.3.14,<0.7",
+    "faststream>=0.3.14,<0.8",
 ]
 
 [project.optional-dependencies]

taskiq_faststream/broker.py

@@ -56,7 +56,9 @@ async def startup(self) -> None:
 
     async def shutdown(self) -> None:
         """Shutdown wrapped FastStream broker."""
-        await self.broker.close()
+        # `stop` replaced `close` in FastStream 0.5.44; `close` removed in 0.7.0.
+        stop = getattr(self.broker, "stop", None) or self.broker.close
+        await stop()
         await super().shutdown()
 
     async def kick(self, message: PatchedMessage) -> None:  # type: ignore[override]