1
+ import selectors
1
2
from socket import socket
2
3
import ssl
3
4
import sys
@@ -124,7 +125,7 @@ class AbstractEventLoop(metaclass=ABCMeta):
124
125
@abstractmethod
125
126
@coroutine
126
127
def create_datagram_endpoint (self , protocol_factory : _ProtocolFactory ,
127
- local_addr : str = ..., remote_addr : str = ..., * ,
128
+ local_addr : Optional [ Tuple [ str , int ]] = ..., remote_addr : Optional [ Tuple [ str , int ]] = ..., * ,
128
129
family : int = ..., proto : int = ..., flags : int = ...,
129
130
reuse_address : Optional [bool ] = ..., reuse_port : Optional [bool ] = ...,
130
131
allow_broadcast : Optional [bool ] = ...,
@@ -146,17 +147,17 @@ class AbstractEventLoop(metaclass=ABCMeta):
146
147
** kwargs : Any ) -> Generator [Any , None , _TransProtPair ]: ...
147
148
@abstractmethod
148
149
@coroutine
149
- def subprocess_exec (self , protocol_factory : _ProtocolFactory , * args : List [ Any ] , stdin : Any = ...,
150
+ def subprocess_exec (self , protocol_factory : _ProtocolFactory , * args : Any , stdin : Any = ...,
150
151
stdout : Any = ..., stderr : Any = ...,
151
152
** kwargs : Any ) -> Generator [Any , None , _TransProtPair ]: ...
152
153
@abstractmethod
153
- def add_reader (self , fd : int , callback : Callable [..., Any ], * args : List [ Any ] ) -> None : ...
154
+ def add_reader (self , fd : selectors . _FileObject , callback : Callable [..., Any ], * args : Any ) -> None : ...
154
155
@abstractmethod
155
- def remove_reader (self , fd : int ) -> None : ...
156
+ def remove_reader (self , fd : selectors . _FileObject ) -> None : ...
156
157
@abstractmethod
157
- def add_writer (self , fd : int , callback : Callable [..., Any ], * args : List [ Any ] ) -> None : ...
158
+ def add_writer (self , fd : selectors . _FileObject , callback : Callable [..., Any ], * args : Any ) -> None : ...
158
159
@abstractmethod
159
- def remove_writer (self , fd : int ) -> None : ...
160
+ def remove_writer (self , fd : selectors . _FileObject ) -> None : ...
160
161
# Completion based I/O methods returning Futures.
161
162
@abstractmethod
162
163
@coroutine
@@ -172,7 +173,7 @@ class AbstractEventLoop(metaclass=ABCMeta):
172
173
def sock_accept (self , sock : socket ) -> Generator [Any , None , Tuple [socket , Any ]]: ...
173
174
# Signal handling.
174
175
@abstractmethod
175
- def add_signal_handler (self , sig : int , callback : Callable [..., Any ], * args : List [ Any ] ) -> None : ...
176
+ def add_signal_handler (self , sig : int , callback : Callable [..., Any ], * args : Any ) -> None : ...
176
177
@abstractmethod
177
178
def remove_signal_handler (self , sig : int ) -> None : ...
178
179
# Error handlers.
0 commit comments