Added functionality to unix_events

This commit is contained in:
itay azolay 2020-01-09 22:45:49 +02:00
parent 7acf410d21
commit a16f4d380c
1 changed files with 5 additions and 1 deletions

View File

@ -460,12 +460,16 @@ class _UnixReadPipeTransport(transports.ReadTransport):
self._loop.call_soon(self._protocol.connection_made, self)
# only start reading when connection_made() has been called
self._loop.call_soon(self._loop._add_reader,
self._loop.call_soon(self._add_reader,
self._fileno, self._read_ready)
if waiter is not None:
# only wake up the waiter when connection_made() has been called
self._loop.call_soon(futures._set_result_unless_cancelled,
waiter, None)
def _add_reader(self, fd, callback):
if not self.is_reading():
return
self._loop._add_reader(fd, callback)
def __repr__(self):
info = [self.__class__.__name__]