mirror of
https://github.com/davidhalter/typeshed.git
synced 2025-12-09 05:24:52 +08:00
17dcea4a68
* run script and do some manual changes (Akuli) * do the whole thing manually (srittau) * merge changes (Akuli) Co-authored-by: Sebastian Rittau <srittau@rittau.biz>
30 lines
1.1 KiB
Python
30 lines
1.1 KiB
Python
import asyncore
|
|
import socket
|
|
from abc import abstractmethod
|
|
from typing import Optional, Union
|
|
|
|
class simple_producer:
|
|
def __init__(self, data: bytes, buffer_size: int = ...) -> None: ...
|
|
def more(self) -> bytes: ...
|
|
|
|
class async_chat(asyncore.dispatcher):
|
|
ac_in_buffer_size: int
|
|
ac_out_buffer_size: int
|
|
def __init__(self, sock: Optional[socket.socket] = ..., map: Optional[asyncore._maptype] = ...) -> None: ...
|
|
@abstractmethod
|
|
def collect_incoming_data(self, data: bytes) -> None: ...
|
|
@abstractmethod
|
|
def found_terminator(self) -> None: ...
|
|
def set_terminator(self, term: Union[bytes, int, None]) -> None: ...
|
|
def get_terminator(self) -> Union[bytes, int, None]: ...
|
|
def handle_read(self) -> None: ...
|
|
def handle_write(self) -> None: ...
|
|
def handle_close(self) -> None: ...
|
|
def push(self, data: bytes) -> None: ...
|
|
def push_with_producer(self, producer: simple_producer) -> None: ...
|
|
def readable(self) -> bool: ...
|
|
def writable(self) -> bool: ...
|
|
def close_when_done(self) -> None: ...
|
|
def initiate_send(self) -> None: ...
|
|
def discard_buffers(self) -> None: ...
|