1
- from typing import Iterable , Tuple , Callable , Any , AnyStr
1
+ from typing import Any , Callable , Generator , Iterable , Tuple
2
2
3
3
ClientConnectedCallback = Callable [[Tuple [StreamReader , StreamWriter ]], None ]
4
4
import socket
@@ -23,7 +23,7 @@ def open_connection(
23
23
* ,
24
24
loop : events .AbstractEventLoop = ...,
25
25
limit : int = ...,
26
- ** kwds : Any ) -> Tuple [StreamReader , StreamWriter ]: ...
26
+ ** kwds : Any ) -> Generator [ Any , None , Tuple [StreamReader , StreamWriter ] ]: ...
27
27
28
28
@coroutines .coroutine
29
29
def start_server (
@@ -62,7 +62,7 @@ class StreamReaderProtocol(FlowControlMixin, protocols.Protocol):
62
62
loop : events .AbstractEventLoop = ...) -> None : ...
63
63
def connection_made (self , transport : transports .BaseTransport ) -> None : ...
64
64
def connection_lost (self , exc : Exception ) -> None : ...
65
- def data_received (self , data : AnyStr ) -> None : ...
65
+ def data_received (self , data : bytes ) -> None : ...
66
66
def eof_received (self ) -> bool : ...
67
67
68
68
class StreamWriter :
@@ -73,12 +73,12 @@ class StreamWriter:
73
73
loop : events .AbstractEventLoop ) -> None : ...
74
74
@property
75
75
def transport (self ) -> transports .BaseTransport : ...
76
- def write (self , data : AnyStr ) -> None : ...
77
- def writelines (self , data : Iterable [str ]) -> None : ...
76
+ def write (self , data : bytes ) -> None : ...
77
+ def writelines (self , data : Iterable [bytes ]) -> None : ...
78
78
def write_eof (self ) -> None : ...
79
79
def can_write_eof (self ) -> bool : ...
80
80
def close (self ) -> None : ...
81
- def get_extra_info (self , name : Any , default : Any = ...) -> Any : ...
81
+ def get_extra_info (self , name : str , default : Any = ...) -> Any : ...
82
82
def drain (self ) -> None : ...
83
83
84
84
class StreamReader :
@@ -90,12 +90,12 @@ class StreamReader:
90
90
def set_transport (self , transport : transports .BaseTransport ) -> None : ...
91
91
def feed_eof (self ) -> None : ...
92
92
def at_eof (self ) -> bool : ...
93
- def feed_data (self , data : AnyStr ): ...
93
+ def feed_data (self , data : bytes ): ...
94
94
@coroutines .coroutine
95
- def readline (self ) -> str : ...
95
+ def readline (self ) -> Generator [ Any , None , bytes ] : ...
96
96
@coroutines .coroutine
97
- def readuntil (self , separator = b'\n ' ) -> str : ...
97
+ def readuntil (self , separator = b'\n ' ) -> Generator [ Any , None , bytes ] : ...
98
98
@coroutines .coroutine
99
- def read (self , n = - 1 ) -> str : ...
99
+ def read (self , n = - 1 ) -> Generator [ Any , None , bytes ] : ...
100
100
@coroutines .coroutine
101
- def readexactly (self , n ) -> str : ...
101
+ def readexactly (self , n ) -> Generator [ Any , None , bytes ] : ...
0 commit comments