2 from logging import Logger
3 from socket import socket
4 from typing import Any, Callable, Mapping
6 from . import compat as compat, utilities as utilities
10 socket_map: Mapping[int, socket]
11 map: Mapping[int, socket]
13 class ExitNow(Exception): ...
15 def read(obj: dispatcher) -> None: ...
16 def write(obj: dispatcher) -> None: ...
17 def readwrite(obj: dispatcher, flags: int) -> None: ...
18 def poll(timeout: float = ..., map: Mapping[int, socket] | None = ...) -> None: ...
19 def poll2(timeout: float = ..., map: Mapping[int, socket] | None = ...) -> None: ...
23 def loop(timeout: float = ..., use_poll: bool = ..., map: Mapping[int, socket] | None = ..., count: int | None = ...) -> None: ...
24 def compact_traceback() -> tuple[tuple[str, str, str], BaseException, BaseException, str]: ...
30 connecting: bool = ...
32 addr: tuple[str, int] | None = ...
33 ignore_log_types: frozenset[Any]
35 compact_traceback: Callable[[], tuple[tuple[str, str, str], BaseException, BaseException, str]] = ...
36 socket: _socket | None = ...
37 def __init__(self, sock: _socket | None = ..., map: Mapping[int, _socket] | None = ...) -> None: ...
38 def add_channel(self, map: Mapping[int, _socket] | None = ...) -> None: ...
39 def del_channel(self, map: Mapping[int, _socket] | None = ...) -> None: ...
40 family_and_type: tuple[int, int] = ...
41 def create_socket(self, family: int = ..., type: int = ...) -> None: ...
42 def set_socket(self, sock: _socket, map: Mapping[int, _socket] | None = ...) -> None: ...
43 def set_reuse_addr(self) -> None: ...
44 def readable(self) -> bool: ...
45 def writable(self) -> bool: ...
46 def listen(self, num: int) -> None: ...
47 def bind(self, addr: tuple[str, int]) -> None: ...
48 def connect(self, address: tuple[str, int]) -> None: ...
49 def accept(self) -> tuple[_socket, tuple[str, int]] | None: ...
50 def send(self, data: bytes) -> int: ...
51 def recv(self, buffer_size: int) -> bytes: ...
52 def close(self) -> None: ...
53 def log(self, message: str) -> None: ...
54 def log_info(self, message: str, type: str = ...) -> None: ...
55 def handle_read_event(self) -> None: ...
56 def handle_connect_event(self) -> None: ...
57 def handle_write_event(self) -> None: ...
58 def handle_expt_event(self) -> None: ...
59 def handle_error(self) -> None: ...
60 def handle_expt(self) -> None: ...
61 def handle_read(self) -> None: ...
62 def handle_write(self) -> None: ...
63 def handle_connect(self) -> None: ...
64 def handle_accept(self) -> None: ...
65 def handle_accepted(self, sock: _socket, addr: Any) -> None: ...
66 def handle_close(self) -> None: ...
68 class dispatcher_with_send(dispatcher):
69 out_buffer: bytes = ...
70 def __init__(self, sock: socket | None = ..., map: Mapping[int, socket] | None = ...) -> None: ...
71 def initiate_send(self) -> None: ...
72 handle_write: Callable[[], None] = ...
73 def writable(self) -> bool: ...
74 def send(self, data: bytes) -> None: ... # type: ignore
76 def close_all(map: Mapping[int, socket] | None = ..., ignore_all: bool = ...) -> None: ...
80 def __init__(self, fd: BytesIO) -> None: ...
81 def __del__(self) -> None: ...
82 def recv(self, *args: Any) -> bytes: ...
83 def send(self, *args: Any) -> bytes: ...
84 def getsockopt(self, level: int, optname: int, buflen: bool | None = ...) -> int: ...
85 read: Callable[..., bytes] = ...
86 write: Callable[..., bytes] = ...
87 def close(self) -> None: ...
88 def fileno(self) -> BytesIO: ...
90 class file_dispatcher(dispatcher):
92 def __init__(self, fd: BytesIO, map: Mapping[int, _socket] | None = ...) -> None: ...
94 def set_file(self, fd: BytesIO) -> None: ...