diff options
| author | Guido van Rossum <guido@python.org> | 2014-01-10 21:26:38 (GMT) |
|---|---|---|
| committer | Guido van Rossum <guido@python.org> | 2014-01-10 21:26:38 (GMT) |
| commit | efef9d3f25b5070a6430259fd3b5703e94c7843d (patch) | |
| tree | 39393fcfb64af63120fa57adac3d85c1a6c0cb8d /Lib/asyncio/streams.py | |
| parent | 2407f3bb1bb77ae8e3752e6ff2f89dc5edd3238e (diff) | |
| download | cpython-efef9d3f25b5070a6430259fd3b5703e94c7843d.zip cpython-efef9d3f25b5070a6430259fd3b5703e94c7843d.tar.gz cpython-efef9d3f25b5070a6430259fd3b5703e94c7843d.tar.bz2 | |
asyncio: Tiny cleanup in streams.py.
Diffstat (limited to 'Lib/asyncio/streams.py')
| -rw-r--r-- | Lib/asyncio/streams.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/Lib/asyncio/streams.py b/Lib/asyncio/streams.py index 7eda5f6..f01f862 100644 --- a/Lib/asyncio/streams.py +++ b/Lib/asyncio/streams.py @@ -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. """ |