Low-level API: asyncio backend is now a private implementation (#311)

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

@@ -17,6 +17,4 @@
 
 from __future__ import annotations
 
-__all__ = ["AsyncIOBackend"]  # type: list[str]
-
-from .backend import AsyncIOBackend
+__all__ = []  # type: list[str]

src/easynetwork/lowlevel/std_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/std_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/std_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/std_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/std_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/std_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/std_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/std_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/std_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/std_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 ...std_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,8 +9,8 @@
 from contextlib import ExitStack
 from typing import TYPE_CHECKING, Any, Literal, Required, TypedDict
 
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
 from easynetwork.lowlevel.api_async.backend.abc import TaskInfo
-from easynetwork.lowlevel.std_asyncio.backend import AsyncIOBackend
 
 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.std_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,8 +6,8 @@
 from collections.abc import AsyncIterator
 from typing import Any
 
+from easynetwork.lowlevel.api_async.backend._asyncio.backend import AsyncIOBackend
 from easynetwork.lowlevel.futures import AsyncExecutor, unwrap_future
-from easynetwork.lowlevel.std_asyncio.backend import AsyncIOBackend
 
 import pytest
 import pytest_asyncio