From bc6da51495609858e9a0fc2da9ea77ab9963e5df Mon Sep 17 00:00:00 2001 From: Shantanu <12621235+hauntsaninja@users.noreply.github.com> Date: Tue, 21 Jul 2020 00:34:00 -0700 Subject: [PATCH] asyncio: export submodules (#4346) Resolves #4345 Co-authored-by: hauntsaninja <> --- stdlib/3/asyncio/__init__.pyi | 55 +++++++++++++++-------------------- 1 file changed, 24 insertions(+), 31 deletions(-) diff --git a/stdlib/3/asyncio/__init__.pyi b/stdlib/3/asyncio/__init__.pyi index 24d59c938..42e7aa9ba 100644 --- a/stdlib/3/asyncio/__init__.pyi +++ b/stdlib/3/asyncio/__init__.pyi @@ -1,7 +1,9 @@ import sys -from asyncio.base_events import BaseEventLoop as BaseEventLoop -from asyncio.coroutines import coroutine as coroutine, iscoroutine as iscoroutine, iscoroutinefunction as iscoroutinefunction -from asyncio.events import ( +from typing import Type + +from .base_events import BaseEventLoop as BaseEventLoop +from .coroutines import coroutine as coroutine, iscoroutine as iscoroutine, iscoroutinefunction as iscoroutinefunction +from .events import ( AbstractEventLoop as AbstractEventLoop, AbstractEventLoopPolicy as AbstractEventLoopPolicy, AbstractServer as AbstractServer, @@ -17,39 +19,36 @@ from asyncio.events import ( set_event_loop as set_event_loop, set_event_loop_policy as set_event_loop_policy, ) -from asyncio.futures import Future as Future, isfuture as isfuture, wrap_future as wrap_future -from asyncio.locks import ( +from .futures import Future as Future, isfuture as isfuture, wrap_future as wrap_future +from .locks import ( BoundedSemaphore as BoundedSemaphore, Condition as Condition, Event as Event, Lock as Lock, Semaphore as Semaphore, ) -from asyncio.protocols import ( +from .protocols import ( BaseProtocol as BaseProtocol, DatagramProtocol as DatagramProtocol, Protocol as Protocol, SubprocessProtocol as SubprocessProtocol, ) -from asyncio.queues import ( +from .queues import ( LifoQueue as LifoQueue, PriorityQueue as PriorityQueue, Queue as Queue, QueueEmpty as QueueEmpty, QueueFull as QueueFull, ) -from asyncio.streams import ( +from .streams import ( StreamReader as StreamReader, StreamReaderProtocol as StreamReaderProtocol, StreamWriter as StreamWriter, open_connection as open_connection, start_server as start_server, ) -from asyncio.subprocess import ( - create_subprocess_exec as create_subprocess_exec, - create_subprocess_shell as create_subprocess_shell, -) -from asyncio.tasks import ( +from .subprocess import create_subprocess_exec as create_subprocess_exec, create_subprocess_shell as create_subprocess_shell +from .tasks import ( ALL_COMPLETED as ALL_COMPLETED, FIRST_COMPLETED as FIRST_COMPLETED, FIRST_EXCEPTION as FIRST_EXCEPTION, @@ -63,7 +62,7 @@ from asyncio.tasks import ( wait as wait, wait_for as wait_for, ) -from asyncio.transports import ( +from .transports import ( BaseTransport as BaseTransport, DatagramTransport as DatagramTransport, ReadTransport as ReadTransport, @@ -71,12 +70,11 @@ from asyncio.transports import ( Transport as Transport, WriteTransport as WriteTransport, ) -from typing import Type if sys.version_info >= (3, 7): - from asyncio.events import get_running_loop as get_running_loop + from .events import get_running_loop as get_running_loop if sys.version_info >= (3, 8): - from asyncio.exceptions import ( + from .exceptions import ( CancelledError as CancelledError, IncompleteReadError as IncompleteReadError, InvalidStateError as InvalidStateError, @@ -86,32 +84,27 @@ if sys.version_info >= (3, 8): ) else: if sys.version_info >= (3, 7): - from asyncio.events import SendfileNotAvailableError as SendfileNotAvailableError - from asyncio.futures import ( - CancelledError as CancelledError, - InvalidStateError as InvalidStateError, - TimeoutError as TimeoutError, - ) - from asyncio.streams import IncompleteReadError as IncompleteReadError, LimitOverrunError as LimitOverrunError + from .events import SendfileNotAvailableError as SendfileNotAvailableError + from .futures import CancelledError as CancelledError, InvalidStateError as InvalidStateError, TimeoutError as TimeoutError + from .streams import IncompleteReadError as IncompleteReadError, LimitOverrunError as LimitOverrunError if sys.version_info >= (3, 7): - from asyncio.protocols import BufferedProtocol as BufferedProtocol + from .protocols import BufferedProtocol as BufferedProtocol if sys.version_info >= (3, 7): - from asyncio.runners import run as run + from .runners import run as run if sys.version_info >= (3, 7): - from asyncio.tasks import all_tasks as all_tasks, create_task as create_task, current_task as current_task + from .tasks import all_tasks as all_tasks, create_task as create_task, current_task as current_task if sys.version_info >= (3, 9): - from asyncio.threads import to_thread as to_thread + from .threads import to_thread as to_thread DefaultEventLoopPolicy: Type[AbstractEventLoopPolicy] if sys.platform == "win32": - from asyncio.windows_events import * + from .windows_events import * if sys.platform != "win32": - from asyncio.streams import open_unix_connection as open_unix_connection, start_unix_server as start_unix_server - + from .streams import open_unix_connection as open_unix_connection, start_unix_server as start_unix_server from .unix_events import ( AbstractChildWatcher as AbstractChildWatcher, FastChildWatcher as FastChildWatcher,