diff options
| author | Victor Stinner <victor.stinner@gmail.com> | 2014-07-08 23:57:31 +0200 |
|---|---|---|
| committer | Victor Stinner <victor.stinner@gmail.com> | 2014-07-08 23:57:31 +0200 |
| commit | bfff45d611f3435ed4b713124f65fba8e961ff03 (patch) | |
| tree | 752da659a58b6ac8178ff41a9d890cd83f2e7177 /Lib/asyncio/unix_events.py | |
| parent | aea82293be0a56937fe807a0d2a44c7db392f155 (diff) | |
| download | cpython-git-bfff45d611f3435ed4b713124f65fba8e961ff03.tar.gz | |
asyncion, Tulip issue 181: BaseEventLoop.create_datagram_endpoint() now waits
until protocol.connection_made() has been called. Document also why transport
constructors use a waiter.
Diffstat (limited to 'Lib/asyncio/unix_events.py')
| -rw-r--r-- | Lib/asyncio/unix_events.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py index 535ea2209b..764e719d41 100644 --- a/Lib/asyncio/unix_events.py +++ b/Lib/asyncio/unix_events.py @@ -269,6 +269,7 @@ class _UnixReadPipeTransport(transports.ReadTransport): self._loop.add_reader(self._fileno, self._read_ready) self._loop.call_soon(self._protocol.connection_made, self) if waiter is not None: + # wait until protocol.connection_made() has been called self._loop.call_soon(waiter._set_result_unless_cancelled, None) def _read_ready(self): @@ -353,6 +354,7 @@ class _UnixWritePipeTransport(transports._FlowControlMixin, self._loop.call_soon(self._protocol.connection_made, self) if waiter is not None: + # wait until protocol.connection_made() has been called self._loop.call_soon(waiter._set_result_unless_cancelled, None) def get_write_buffer_size(self): |