mirror of
https://github.com/davidhalter/typeshed.git
synced 2025-12-10 05:51:52 +08:00
add (overwrite with) mypy stubs, if available
This commit is contained in:
Matthias Kramm
13
stdlib/3.4/asyncio/__init__.pyi
Normal file
13
stdlib/3.4/asyncio/__init__.pyi
Normal file
@@ -0,0 +1,13 @@
|
||||
"""The asyncio package, tracking PEP 3156."""
|
||||
from asyncio.futures import Future
|
||||
from asyncio.tasks import (coroutine, sleep, Task, FIRST_COMPLETED,
|
||||
FIRST_EXCEPTION, ALL_COMPLETED, wait, wait_for)
|
||||
from asyncio.events import (AbstractEventLoopPolicy, AbstractEventLoop,
|
||||
Handle, get_event_loop)
|
||||
from asyncio.queues import (Queue, PriorityQueue, LifoQueue, JoinableQueue,
|
||||
QueueFull, QueueEmpty)
|
||||
|
||||
__all__ = (futures.__all__ +
|
||||
tasks.__all__ +
|
||||
events.__all__ +
|
||||
queues.__all__)
|
||||
172
stdlib/3.4/asyncio/events.pyi
Normal file
172
stdlib/3.4/asyncio/events.pyi
Normal file
@@ -0,0 +1,172 @@
|
||||
from typing import Any, TypeVar, List, Callable, Tuple, Union, Dict
|
||||
from abc import ABCMeta, abstractmethod
|
||||
from asyncio.futures import Future
|
||||
|
||||
# __all__ = ['AbstractServer',
|
||||
# 'TimerHandle',
|
||||
# 'get_event_loop_policy', 'set_event_loop_policy',
|
||||
# 'set_event_loop', 'new_event_loop',
|
||||
# 'get_child_watcher', 'set_child_watcher',
|
||||
# ]
|
||||
|
||||
|
||||
__all__ = ['AbstractEventLoopPolicy', 'AbstractEventLoop', 'Handle', 'get_event_loop']
|
||||
|
||||
_T = TypeVar('_T')
|
||||
|
||||
PIPE = ... # type: Any # from subprocess.PIPE
|
||||
|
||||
AF_UNSPEC = 0 # from socket
|
||||
AI_PASSIVE = 0
|
||||
|
||||
class Handle:
|
||||
__slots__ = [] # type: List[str]
|
||||
_cancelled = False
|
||||
_args = [] # type: List[Any]
|
||||
def __init__(self, callback: Callable[[],Any], args: List[Any],
|
||||
loop: AbstractEventLoop) -> None: ...
|
||||
def __repr__(self) -> str: ...
|
||||
def cancel(self) -> None: ...
|
||||
def _run(self) -> None: ...
|
||||
|
||||
|
||||
class AbstractEventLoop(metaclass=ABCMeta):
|
||||
@abstractmethod
|
||||
def run_forever(self) -> None: ...
|
||||
@abstractmethod
|
||||
def run_until_complete(self, future: Future[_T]) -> _T: ...
|
||||
@abstractmethod
|
||||
def stop(self) -> None: ...
|
||||
@abstractmethod
|
||||
def is_running(self) -> bool: ...
|
||||
@abstractmethod
|
||||
def close(self) -> None: ...
|
||||
# Methods scheduling callbacks. All these return Handles.
|
||||
@abstractmethod
|
||||
def call_soon(self, callback: Callable[[],Any], *args: Any) -> Handle: ...
|
||||
@abstractmethod
|
||||
def call_later(self, delay: Union[int, float], callback: Callable[[],Any], *args: Any) -> Handle: ...
|
||||
@abstractmethod
|
||||
def call_at(self, when: float, callback: Callable[[],Any], *args: Any) -> Handle: ...
|
||||
@abstractmethod
|
||||
def time(self) -> float: ...
|
||||
# Methods for interacting with threads
|
||||
@abstractmethod
|
||||
def call_soon_threadsafe(self, callback: Callable[[],Any], *args: Any) -> Handle: ...
|
||||
@abstractmethod
|
||||
def run_in_executor(self, executor: Any,
|
||||
callback: Callable[[],Any], *args: Any) -> Future[Any]: ...
|
||||
@abstractmethod
|
||||
def set_default_executor(self, executor: Any) -> None: ...
|
||||
# Network I/O methods returning Futures.
|
||||
@abstractmethod
|
||||
def getaddrinfo(self, host: str, port: int, *,
|
||||
family: int = 0, type: int = 0, proto: int = 0, flags: int = 0) -> List[Tuple[int, int, int, str, tuple]]: ...
|
||||
@abstractmethod
|
||||
def getnameinfo(self, sockaddr: tuple, flags: int = 0) -> Tuple[str, int]: ...
|
||||
@abstractmethod
|
||||
def create_connection(self, protocol_factory: Any, host: str = None, port: int = None, *,
|
||||
ssl: Any = None, family: int = 0, proto: int = 0, flags: int = 0, sock: Any = None,
|
||||
local_addr: str = None, server_hostname: str = None) -> tuple: ...
|
||||
# ?? check Any
|
||||
# return (Transport, Protocol)
|
||||
@abstractmethod
|
||||
def create_server(self, protocol_factory: Any, host: str = None, port: int = None, *,
|
||||
family: int = AF_UNSPEC, flags: int = AI_PASSIVE,
|
||||
sock: Any = None, backlog: int = 100, ssl: Any = None, reuse_address: Any = None) -> Any: ...
|
||||
# ?? check Any
|
||||
# return Server
|
||||
@abstractmethod
|
||||
def create_unix_connection(self, protocol_factory: Any, path: str, *,
|
||||
ssl: Any = None, sock: Any = None,
|
||||
server_hostname: str = None) -> tuple: ...
|
||||
# ?? check Any
|
||||
# return tuple(Transport, Protocol)
|
||||
@abstractmethod
|
||||
def create_unix_server(self, protocol_factory: Any, path: str, *,
|
||||
sock: Any = None, backlog: int = 100, ssl: Any = None) -> Any: ...
|
||||
# ?? check Any
|
||||
# return Server
|
||||
@abstractmethod
|
||||
def create_datagram_endpoint(self, protocol_factory: Any,
|
||||
local_addr: str = None, remote_addr: str = None, *,
|
||||
family: int = 0, proto: int = 0, flags: int = 0) -> tuple: ...
|
||||
#?? check Any
|
||||
# return (Transport, Protocol)
|
||||
# Pipes and subprocesses.
|
||||
@abstractmethod
|
||||
def connect_read_pipe(self, protocol_factory: Any, pipe: Any) -> tuple: ...
|
||||
#?? check Any
|
||||
# return (Transport, Protocol)
|
||||
@abstractmethod
|
||||
def connect_write_pipe(self, protocol_factory: Any, pipe: Any) -> tuple: ...
|
||||
#?? check Any
|
||||
# return (Transport, Protocol)
|
||||
@abstractmethod
|
||||
def subprocess_shell(self, protocol_factory: Any, cmd: Union[bytes, str], *, stdin: Any = PIPE,
|
||||
stdout: Any = PIPE, stderr: Any = PIPE,
|
||||
**kwargs: Dict[str, Any]) -> tuple: ...
|
||||
#?? check Any
|
||||
# return (Transport, Protocol)
|
||||
@abstractmethod
|
||||
def subprocess_exec(self, protocol_factory: Any, *args: List[Any], stdin: Any = PIPE,
|
||||
stdout: Any = PIPE, stderr: Any = PIPE,
|
||||
**kwargs: Dict[str, Any]) -> tuple: ...
|
||||
#?? check Any
|
||||
# return (Transport, Protocol)
|
||||
@abstractmethod
|
||||
def add_reader(self, fd: int, callback: Callable[[],Any], *args: List[Any]) -> None: ...
|
||||
@abstractmethod
|
||||
def remove_reader(self, fd: int) -> None: ...
|
||||
@abstractmethod
|
||||
def add_writer(self, fd: int, callback: Callable[[],Any], *args: List[Any]) -> None: ...
|
||||
@abstractmethod
|
||||
def remove_writer(self, fd: int) -> None: ...
|
||||
# Completion based I/O methods returning Futures.
|
||||
@abstractmethod
|
||||
def sock_recv(self, sock: Any, nbytes: int) -> Any: ... #TODO
|
||||
@abstractmethod
|
||||
def sock_sendall(self, sock: Any, data: bytes) -> None: ... #TODO
|
||||
@abstractmethod
|
||||
def sock_connect(self, sock: Any, address: str) -> Any: ... #TODO
|
||||
@abstractmethod
|
||||
def sock_accept(self, sock: Any) -> Any: ...
|
||||
# Signal handling.
|
||||
@abstractmethod
|
||||
def add_signal_handler(self, sig: int, callback: Callable[[],Any], *args: List[Any]) -> None: ...
|
||||
@abstractmethod
|
||||
def remove_signal_handler(self, sig: int) -> None: ...
|
||||
# Error handlers.
|
||||
@abstractmethod
|
||||
def set_exception_handler(self, handler: Callable[[], Any]) -> None: ...
|
||||
@abstractmethod
|
||||
def default_exception_handler(self, context: Any) -> None: ...
|
||||
@abstractmethod
|
||||
def call_exception_handler(self, context: Any) -> None: ...
|
||||
# Debug flag management.
|
||||
@abstractmethod
|
||||
def get_debug(self) -> bool: ...
|
||||
@abstractmethod
|
||||
def set_debug(self, enabled: bool) -> None: ...
|
||||
|
||||
class AbstractEventLoopPolicy(metaclass=ABCMeta):
|
||||
@abstractmethod
|
||||
def get_event_loop(self) -> AbstractEventLoop: ...
|
||||
@abstractmethod
|
||||
def set_event_loop(self, loop: AbstractEventLoop): ...
|
||||
@abstractmethod
|
||||
def new_event_loop(self) -> Any: ... # return selector_events.BaseSelectorEventLoop
|
||||
# Child processes handling (Unix only).
|
||||
@abstractmethod
|
||||
def get_child_watcher(self) -> Any: ... # return unix_events.AbstractChildWatcher
|
||||
@abstractmethod
|
||||
def set_child_watcher(self, watcher: Any) -> None: ... # gen unix_events.AbstractChildWatcher
|
||||
|
||||
class BaseDefaultEventLoopPolicy(AbstractEventLoopPolicy):
|
||||
def __init__(self) -> None: ...
|
||||
def get_event_loop(self) -> AbstractEventLoop: ...
|
||||
def set_event_loop(self, loop: AbstractEventLoop): ...
|
||||
def new_event_loop(self) -> Any: ... # Same return than AbstractEventLoop
|
||||
|
||||
|
||||
def get_event_loop() -> AbstractEventLoop: ...
|
||||
41
stdlib/3.4/asyncio/futures.pyi
Normal file
41
stdlib/3.4/asyncio/futures.pyi
Normal file
@@ -0,0 +1,41 @@
|
||||
from typing import Any, Callable, TypeVar, List, Generic, Iterable, Iterator
|
||||
from asyncio.events import AbstractEventLoop
|
||||
# __all__ = ['CancelledError', 'TimeoutError',
|
||||
# 'InvalidStateError',
|
||||
# 'wrap_future',
|
||||
# ]
|
||||
__all__ = ['Future']
|
||||
|
||||
_T = TypeVar('_T')
|
||||
|
||||
class _TracebackLogger:
|
||||
__slots__ = [] # type: List[str]
|
||||
exc = Any # Exception
|
||||
tb = [] # type: List[str]
|
||||
def __init__(self, exc: Any, loop: AbstractEventLoop) -> None: ...
|
||||
def activate(self) -> None: ...
|
||||
def clear(self) -> None: ...
|
||||
def __del__(self) -> None: ...
|
||||
|
||||
class Future(Iterator[_T], Generic[_T]):
|
||||
_state = ''
|
||||
_exception = Any #Exception
|
||||
_blocking = False
|
||||
_log_traceback = False
|
||||
_tb_logger = _TracebackLogger
|
||||
def __init__(self, *, loop: AbstractEventLoop = None) -> None: ...
|
||||
def __repr__(self) -> str: ...
|
||||
def __del__(self) -> None: ...
|
||||
def cancel(self) -> bool: ...
|
||||
def _schedule_callbacks(self) -> None: ...
|
||||
def cancelled(self) -> bool: ...
|
||||
def done(self) -> bool: ...
|
||||
def result(self) -> _T: ...
|
||||
def exception(self) -> Any: ...
|
||||
def add_done_callback(self, fn: Callable[[Future[_T]], Any]) -> None: ...
|
||||
def remove_done_callback(self, fn: Callable[[Future[_T]], Any]) -> int: ...
|
||||
def set_result(self, result: _T) -> None: ...
|
||||
def set_exception(self, exception: Any) -> None: ...
|
||||
def _copy_state(self, other: Any) -> None: ...
|
||||
def __iter__(self) -> Iterator[_T]: ...
|
||||
def __next__(self) -> _T: ...
|
||||
47
stdlib/3.4/asyncio/queues.pyi
Normal file
47
stdlib/3.4/asyncio/queues.pyi
Normal file
@@ -0,0 +1,47 @@
|
||||
from typing import TypeVar, Generic
|
||||
|
||||
__all__ = ['Queue', 'PriorityQueue', 'LifoQueue', 'JoinableQueue',
|
||||
'QueueFull', 'QueueEmpty']
|
||||
|
||||
from asyncio.events import AbstractEventLoop
|
||||
from .tasks import coroutine
|
||||
|
||||
|
||||
class QueueEmpty(Exception): ...
|
||||
class QueueFull(Exception): ...
|
||||
|
||||
T = TypeVar('T')
|
||||
|
||||
class Queue(Generic[T]):
|
||||
def __init__(self, maxsize: int = 0, *, loop: AbstractEventLoop = None) -> None: ...
|
||||
def _init(self, maxsize: int) -> None: ...
|
||||
def _get(self) -> T: ...
|
||||
def _put(self, item: T) -> None: ...
|
||||
def __repr__(self) -> str: ...
|
||||
def __str__(self) -> str: ...
|
||||
def _format(self) -> str: ...
|
||||
def _consume_done_getters(self) -> None: ...
|
||||
def _consume_done_putters(self) -> None: ...
|
||||
def qsize(self) -> int: ...
|
||||
@property
|
||||
def maxsize(self) -> int: ...
|
||||
def empty(self) -> bool: ...
|
||||
def full(self) -> bool: ...
|
||||
@coroutine
|
||||
def put(self, item: T) -> None: ...
|
||||
def put_nowait(self, item: T) -> None: ...
|
||||
@coroutine
|
||||
def get(self) -> T: ...
|
||||
def get_nowait(self) -> T: ...
|
||||
|
||||
|
||||
class PriorityQueue(Queue): ...
|
||||
|
||||
|
||||
class LifoQueue(Queue): ...
|
||||
|
||||
|
||||
class JoinableQueue(Queue):
|
||||
def task_done(self) -> None: ...
|
||||
@coroutine
|
||||
def join(self) -> None: ...
|
||||
38
stdlib/3.4/asyncio/tasks.pyi
Normal file
38
stdlib/3.4/asyncio/tasks.pyi
Normal file
@@ -0,0 +1,38 @@
|
||||
from typing import Any, Iterable, TypeVar, Set, Dict, List, TextIO, Union, Tuple, Generic, Callable
|
||||
from asyncio.events import AbstractEventLoop
|
||||
from asyncio.futures import Future
|
||||
# __all__ = ['iscoroutinefunction', 'iscoroutine',
|
||||
# 'as_completed', 'async',
|
||||
# 'gather', 'shield',
|
||||
# ]
|
||||
|
||||
__all__ = ['coroutine', 'Task', 'sleep',
|
||||
'FIRST_COMPLETED', 'FIRST_EXCEPTION', 'ALL_COMPLETED',
|
||||
'wait', 'wait_for']
|
||||
|
||||
FIRST_EXCEPTION = 'FIRST_EXCEPTION'
|
||||
FIRST_COMPLETED = 'FIRST_COMPLETED'
|
||||
ALL_COMPLETED = 'ALL_COMPLETED'
|
||||
_T = TypeVar('_T')
|
||||
def coroutine(f: _T) -> _T: ... # Here comes and go a function
|
||||
def sleep(delay: float, result: _T = None, loop: AbstractEventLoop = None) -> Future[_T]: ...
|
||||
def wait(fs: List[Task[_T]], *, loop: AbstractEventLoop = None,
|
||||
timeout: float = None, return_when: str = ALL_COMPLETED) -> Future[Tuple[Set[Future[_T]], Set[Future[_T]]]]: ...
|
||||
def wait_for(fut: Future[_T], timeout: float, *, loop: AbstractEventLoop = None) -> Future[_T]: ...
|
||||
|
||||
|
||||
class Task(Future[_T], Generic[_T]):
|
||||
_all_tasks = None # type: Set[Task]
|
||||
_current_tasks = {} # type: Dict[AbstractEventLoop, Task]
|
||||
@classmethod
|
||||
def current_task(cls, loop: AbstractEventLoop = None) -> Task: ...
|
||||
@classmethod
|
||||
def all_tasks(cls, loop: AbstractEventLoop = None) -> Set[Task]: ...
|
||||
def __init__(self, coro: Future[_T], *, loop: AbstractEventLoop = None) -> None: ...
|
||||
def __repr__(self) -> str: ...
|
||||
def get_stack(self, *, limit: int = None) -> List[Any]: ... # return List[stackframe]
|
||||
def print_stack(self, *, limit: int = None, file: TextIO = None) -> None: ...
|
||||
def cancel(self) -> bool: ...
|
||||
def _step(self, value: Any = None, exc: Exception = None) -> None: ...
|
||||
def _wakeup(self, future: Future[Any]) -> None: ...
|
||||
|
||||
Reference in New Issue
Block a user