]> granicus.if.org Git - python/commitdiff
asyncio: Tiny cleanup in streams.py.
authorGuido van Rossum <guido@python.org>
Fri, 10 Jan 2014 21:26:38 +0000 (13:26 -0800)
committerGuido van Rossum <guido@python.org>
Fri, 10 Jan 2014 21:26:38 +0000 (13:26 -0800)
Lib/asyncio/streams.py

index 7eda5f663251de8b8b51b2758a44f1f8c16fd058..f01f8629a7f055ef30696207313f5c333021f543 100644 (file)
@@ -38,7 +38,7 @@ def open_connection(host=None, port=None, *,
     if loop is None:
         loop = events.get_event_loop()
     reader = StreamReader(limit=limit, loop=loop)
-    protocol = StreamReaderProtocol(reader)
+    protocol = StreamReaderProtocol(reader, loop=loop)
     transport, _ = yield from loop.create_connection(
         lambda: protocol, host, port, **kwds)
     writer = StreamWriter(transport, protocol, reader, loop)
@@ -151,7 +151,7 @@ class StreamWriter:
     This exposes write(), writelines(), [can_]write_eof(),
     get_extra_info() and close().  It adds drain() which returns an
     optional Future on which you can wait for flow control.  It also
-    adds a transport attribute which references the Transport
+    adds a transport property which references the Transport
     directly.
     """