Fixed shutdown events support.

Signed-off-by: Pavel Kirilin <win10@list.ru>

Author: s3rius

.github/workflows/test.yaml

@@ -79,7 +79,7 @@ jobs:
         if: matrix.py_version == '3.9'
         with:
           token: ${{ secrets.CODECOV_TOKEN }}
-          fail_ci_if_error: true
+          fail_ci_if_error: false
           verbose: true
       - name: Stop containers
         if: always()

taskiq_nats/broker.py

@@ -79,3 +79,4 @@ async def listen(self) -> AsyncGenerator[BrokerMessage, None]:
     async def shutdown(self) -> None:
         """Close connections to NATS."""
         await self.client.close()
+        await super().shutdown()