diff --git a/faststream/_internal/application.py b/faststream/_internal/application.py index dd0140db4d..f5c1ba9601 100644 --- 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