Tulip issue #181: BaseEventLoop.create_datagram_endpoint() now waits until

protocol.connection_made() has been called. Document also why transport
constructors use a waiter.

1 files changed, 5 insertions, 2 deletions

diff --git a/asyncio/base_events.py b/asyncio/base_events.py
index 52c5517..833f81d 100644
--- a/asyncio/base_events.py
+++ b/asyncio/base_events.py
@@ -169,7 +169,7 @@ class BaseEventLoop(events.AbstractEventLoop):
         raise NotImplementedError
 
     def _make_datagram_transport(self, sock, protocol,
-                                 address=None, extra=None):
+                                 address=None, waiter=None, extra=None):
         """Create datagram transport."""
         raise NotImplementedError
 
@@ -605,7 +605,10 @@ class BaseEventLoop(events.AbstractEventLoop):
             raise exceptions[0]
 
         protocol = protocol_factory()
-        transport = self._make_datagram_transport(sock, protocol, r_addr)
+        waiter = futures.Future(loop=self)
+        transport = self._make_datagram_transport(sock, protocol, r_addr,
+                                                  waiter)
+        yield from waiter
         return transport, protocol
 
     @coroutine