Low-level API: Moved easynetwork.lowlevel._asyncio in easynetwork.low…

…level.api_async.backend

src/easynetwork/lowlevel/_asyncio/_asyncio_utils.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/_asyncio_utils.py

@@ -37,7 +37,7 @@
 from collections.abc import Iterable, Sequence
 from typing import Any, cast
 
-from .. import _utils
+from .... import _utils
 
 
 async def ensure_resolved(

src/easynetwork/lowlevel/_asyncio/_flow_control.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/_flow_control.py

@@ -25,7 +25,7 @@
 import types
 from collections.abc import Callable
 
-from .. import _utils
+from .... import _utils
 from .tasks import TaskUtils
 
 

src/easynetwork/lowlevel/_asyncio/backend.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/backend.py

@@ -30,10 +30,10 @@
 from collections.abc import Awaitable, Callable, Coroutine, Mapping, Sequence
 from typing import Any, NoReturn, ParamSpec, TypeVar, TypeVarTuple
 
-from .. import _utils
-from ..api_async.backend import _sniffio_helpers
-from ..api_async.backend.abc import AsyncBackend as AbstractAsyncBackend, ILock, TaskInfo
-from ..constants import HAPPY_EYEBALLS_DELAY as _DEFAULT_HAPPY_EYEBALLS_DELAY
+from .... import _utils
+from ....constants import HAPPY_EYEBALLS_DELAY as _DEFAULT_HAPPY_EYEBALLS_DELAY
+from .. import _sniffio_helpers
+from ..abc import AsyncBackend as AbstractAsyncBackend, ILock, TaskInfo
 from ._asyncio_utils import (
     create_connection,
     create_datagram_connection,

src/easynetwork/lowlevel/_asyncio/datagram/endpoint.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/datagram/endpoint.py

@@ -31,7 +31,7 @@
 import warnings
 from typing import Any, final
 
-from ... import _utils
+from ..... import _utils
 from .._flow_control import WriteFlowControl
 
 

src/easynetwork/lowlevel/_asyncio/datagram/listener.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/datagram/listener.py

@@ -29,9 +29,9 @@
 from collections.abc import Callable, Coroutine, Mapping
 from typing import Any, NoReturn, final
 
-from ... import _utils, socket as socket_tools
-from ...api_async.backend.abc import AsyncBackend, TaskGroup
-from ...api_async.transports import abc as transports
+from ..... import _utils, socket as socket_tools
+from ....transports import abc as transports
+from ...abc import AsyncBackend, TaskGroup
 from .._flow_control import WriteFlowControl
 from .endpoint import _monkeypatch_transport
 

src/easynetwork/lowlevel/_asyncio/datagram/socket.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/datagram/socket.py

@@ -25,9 +25,9 @@
 from collections.abc import Callable, Mapping
 from typing import Any, final
 
-from ... import _utils, socket as socket_tools
-from ...api_async.backend.abc import AsyncBackend
-from ...api_async.transports.abc import AsyncDatagramTransport
+from ..... import _utils, socket as socket_tools
+from ....transports.abc import AsyncDatagramTransport
+from ...abc import AsyncBackend
 from .endpoint import DatagramEndpoint
 
 

src/easynetwork/lowlevel/_asyncio/stream/listener.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/stream/listener.py

@@ -36,9 +36,9 @@
 from collections.abc import Callable, Coroutine, Mapping
 from typing import Any, Generic, NoReturn, TypeVar, final
 
-from ... import _utils, constants, socket as socket_tools
-from ...api_async.backend.abc import AsyncBackend, CancelScope, TaskGroup
-from ...api_async.transports.abc import AsyncListener, AsyncStreamTransport
+from ..... import _utils, constants, socket as socket_tools
+from ....transports.abc import AsyncListener, AsyncStreamTransport
+from ...abc import AsyncBackend, CancelScope, TaskGroup
 from ..tasks import TaskUtils
 from .socket import AsyncioTransportStreamSocketAdapter, StreamReaderBufferedProtocol
 

src/easynetwork/lowlevel/_asyncio/stream/socket.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/stream/socket.py

@@ -27,10 +27,10 @@
 from types import TracebackType
 from typing import TYPE_CHECKING, Any, final
 
-from ....exceptions import UnsupportedOperation
-from ... import _utils, socket as socket_tools
-from ...api_async.backend.abc import AsyncBackend
-from ...api_async.transports.abc import AsyncStreamTransport
+from ......exceptions import UnsupportedOperation
+from ..... import _utils, socket as socket_tools
+from ....transports.abc import AsyncStreamTransport
+from ...abc import AsyncBackend
 from .._asyncio_utils import add_flowcontrol_defaults
 from .._flow_control import WriteFlowControl
 

src/easynetwork/lowlevel/_asyncio/tasks.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/tasks.py

@@ -31,14 +31,9 @@
 from typing import Any, ClassVar, NamedTuple, Self, TypeVar, TypeVarTuple, cast, final
 from weakref import WeakKeyDictionary
 
-from .. import _utils
-from .._final import runtime_final_class
-from ..api_async.backend.abc import (
-    CancelScope as AbstractCancelScope,
-    Task as AbstractTask,
-    TaskGroup as AbstractTaskGroup,
-    TaskInfo,
-)
+from .... import _utils
+from ...._final import runtime_final_class
+from ..abc import CancelScope as AbstractCancelScope, Task as AbstractTask, TaskGroup as AbstractTaskGroup, TaskInfo
 
 _T = TypeVar("_T")
 _T_co = TypeVar("_T_co", covariant=True)

src/easynetwork/lowlevel/_asyncio/threads.py → src/easynetwork/lowlevel/api_async/backend/_asyncio/threads.py

@@ -28,10 +28,10 @@
 from types import TracebackType
 from typing import ParamSpec, Self, TypeVar, final
 
-from .. import _lock, _utils
-from .._final import runtime_final_class
-from ..api_async.backend import _sniffio_helpers
-from ..api_async.backend.abc import ThreadsPortal as AbstractThreadsPortal
+from .... import _lock, _utils
+from ...._final import runtime_final_class
+from .. import _sniffio_helpers
+from ..abc import ThreadsPortal as AbstractThreadsPortal
 from .tasks import TaskUtils
 
 _P = ParamSpec("_P")

src/easynetwork/lowlevel/api_async/backend/utils.py

@@ -57,7 +57,7 @@ def ensure_backend(backend: AsyncBackend | BuiltinAsyncBackendLiteral | None) ->
 
     match backend:
         case "asyncio":
-            from ..._asyncio.backend import AsyncIOBackend
+            from ._asyncio.backend import AsyncIOBackend
 
             return AsyncIOBackend()
         case AsyncBackend():

tests/functional_test/test_async/test_backend/test_asyncio_backend.py

@@ -9,7 +9,7 @@
 from contextlib import ExitStack
 from typing import TYPE_CHECKING, Any, Literal, Required, TypedDict
 
-from easynetwork.lowlevel._asyncio.backend import AsyncIOBackend
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
 from easynetwork.lowlevel.api_async.backend.abc import TaskInfo
 
 import pytest
@@ -1226,7 +1226,7 @@ def cancel_shielded_coroutine(
             case "run_in_thread":
                 return lambda: backend.run_in_thread(time.sleep, 0.1)
             case "cancel_shielded_wait_asyncio_futures":
-                from easynetwork.lowlevel._asyncio.tasks import TaskUtils
+                from easynetwork.lowlevel.api_async.backend._asyncio.tasks import TaskUtils
 
                 async def cancel_shielded_wait_asyncio_futures() -> None:
                     loop = asyncio.get_running_loop()

tests/functional_test/test_async/test_futures.py

@@ -6,7 +6,7 @@
 from collections.abc import AsyncIterator
 from typing import Any
 
-from easynetwork.lowlevel._asyncio.backend import AsyncIOBackend
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
 from easynetwork.lowlevel.futures import AsyncExecutor, unwrap_future
 
 import pytest

tests/functional_test/test_communication/test_async/test_client/test_udp.py

@@ -7,7 +7,7 @@
 
 from easynetwork.clients.async_udp import AsyncUDPNetworkClient
 from easynetwork.exceptions import ClientClosedError, DatagramProtocolParseError
-from easynetwork.lowlevel._asyncio.datagram.endpoint import DatagramEndpoint, create_datagram_endpoint
+from easynetwork.lowlevel.api_async.backend._asyncio.datagram.endpoint import DatagramEndpoint, create_datagram_endpoint
 from easynetwork.lowlevel.socket import IPv4SocketAddress, IPv6SocketAddress, SocketProxy
 from easynetwork.protocol import DatagramProtocol
 

tests/functional_test/test_communication/test_async/test_server/test_tcp.py

@@ -16,9 +16,9 @@
     IncrementalDeserializeError,
     StreamProtocolParseError,
 )
-from easynetwork.lowlevel._asyncio._asyncio_utils import create_connection
-from easynetwork.lowlevel._asyncio.backend import AsyncIOBackend
-from easynetwork.lowlevel._asyncio.stream.listener import ListenerSocketAdapter
+from easynetwork.lowlevel.api_async.backend._asyncio._asyncio_utils import create_connection
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
+from easynetwork.lowlevel.api_async.backend._asyncio.stream.listener import ListenerSocketAdapter
 from easynetwork.lowlevel.api_async.backend.abc import AsyncBackend
 from easynetwork.lowlevel.socket import SocketAddress, enable_socket_linger
 from easynetwork.protocol import AnyStreamProtocolType

tests/functional_test/test_communication/test_async/test_server/test_udp.py

@@ -8,9 +8,9 @@
 from typing import Any
 
 from easynetwork.exceptions import BaseProtocolParseError, ClientClosedError, DatagramProtocolParseError, DeserializeError
-from easynetwork.lowlevel._asyncio.backend import AsyncIOBackend
-from easynetwork.lowlevel._asyncio.datagram.endpoint import DatagramEndpoint, create_datagram_endpoint
-from easynetwork.lowlevel._asyncio.datagram.listener import DatagramListenerSocketAdapter
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
+from easynetwork.lowlevel.api_async.backend._asyncio.datagram.endpoint import DatagramEndpoint, create_datagram_endpoint
+from easynetwork.lowlevel.api_async.backend._asyncio.datagram.listener import DatagramListenerSocketAdapter
 from easynetwork.lowlevel.socket import SocketAddress
 from easynetwork.protocol import DatagramProtocol
 from easynetwork.servers.async_udp import AsyncUDPNetworkServer

tests/unit_test/test_async/conftest.py

@@ -4,7 +4,7 @@
 from collections.abc import Callable, Iterable
 from typing import TYPE_CHECKING
 
-from easynetwork.lowlevel._asyncio.backend import AsyncIOBackend
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
 from easynetwork.lowlevel.api_async.backend.abc import AsyncBackend
 from easynetwork.lowlevel.api_async.transports.abc import AsyncDatagramTransport, AsyncStreamTransport
 
@@ -51,7 +51,7 @@ def fake_cancellation_cls() -> type[BaseException]:
 
 @pytest.fixture
 def mock_backend(fake_cancellation_cls: type[BaseException], mocker: MockerFixture) -> MagicMock:
-    from easynetwork.lowlevel._asyncio.tasks import CancelScope, TaskGroup
+    from easynetwork.lowlevel.api_async.backend._asyncio.tasks import CancelScope, TaskGroup
 
     from .._utils import AsyncDummyLock
 

tests/unit_test/test_async/test_asyncio_backend/conftest.py

@@ -4,7 +4,7 @@
 from collections.abc import Callable
 from typing import TYPE_CHECKING
 
-from easynetwork.lowlevel._asyncio.datagram.endpoint import DatagramEndpoint
+from easynetwork.lowlevel.api_async.backend._asyncio.datagram.endpoint import DatagramEndpoint
 
 import pytest