fix (#1837): explicit asyncio.Event usage

airtai · Oct 7, 2024 · 4af443e · 4af443e
1 parent 7fbe3ab
commit 4af443e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/faststream/_internal/application.py b/faststream/_internal/application.py
@@ -1,3 +1,4 @@
+import asyncio
 import logging
 from abc import ABC, abstractmethod
 from typing import (
@@ -12,7 +13,6 @@
     Union,
 )
 
-import anyio
 from typing_extensions import ParamSpec
 
 from faststream.asyncapi.proto import AsyncAPIApplication
@@ -71,7 +71,7 @@ def __init__(
     ) -> None:
         context.set_global("app", self)
 
-        self._should_exit = anyio.Event()
+        self._should_exit = asyncio.Event()  # TODO: move it to anyio
         self.broker = broker
         self.logger = logger
         self.context = context