1 from abc import abstractmethod
\r
5 from typing import Optional, Sequence, Tuple, Union
\r
8 class simple_producer:
\r
9 def __init__(self, data: bytes, buffer_size: int = ...) -> None: ...
\r
10 def more(self) -> bytes: ...
\r
12 class async_chat(asyncore.dispatcher):
\r
13 ac_in_buffer_size = ... # type: int
\r
14 ac_out_buffer_size = ... # type: int
\r
15 def __init__(self, sock: Optional[socket.socket] = ..., map: Optional[asyncore._maptype] = ...) -> None: ...
\r
18 def collect_incoming_data(self, data: bytes) -> None: ...
\r
20 def found_terminator(self) -> None: ...
\r
21 def set_terminator(self, term: Union[bytes, int, None]) -> None: ...
\r
22 def get_terminator(self) -> Union[bytes, int, None]: ...
\r
23 def handle_read(self) -> None: ...
\r
24 def handle_write(self) -> None: ...
\r
25 def handle_close(self) -> None: ...
\r
26 def push(self, data: bytes) -> None: ...
\r
27 def push_with_producer(self, producer: simple_producer) -> None: ...
\r
28 def readable(self) -> bool: ...
\r
29 def writable(self) -> bool: ...
\r
30 def close_when_done(self) -> None: ...
\r
31 def initiate_send(self) -> None: ...
\r
32 def discard_buffers(self) -> None: ...
\r
34 if sys.version_info < (3, 0):
\r
36 def __init__(self, list: Sequence[Union[bytes, simple_producer]] = ...) -> None: ...
\r
37 def __len__(self) -> int: ...
\r
38 def is_empty(self) -> bool: ...
\r
39 def first(self) -> bytes: ...
\r
40 def push(self, data: Union[bytes, simple_producer]) -> None: ...
\r
41 def pop(self) -> Tuple[int, bytes]: ...
\r