Mirror
/
cpython
mirror of https://github.com/python/cpython
4
1
Fork 0
Code Issues Releases Wiki Activity

asyncio: Tiny cleanup in streams.py.

This commit is contained in:
Guido van Rossum 2014-01-10 13:26:38 -08:00
parent 2407f3bb1b
commit efef9d3f25
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Lib/asyncio/streams.py
View File

@ -38,7 +38,7 @@ def open_connection(host=None, port=None, *,
if loop is None: if loop is None:
loop = events.get_event_loop() loop = events.get_event_loop()
reader = StreamReader(limit=limit, loop=loop) reader = StreamReader(limit=limit, loop=loop)
protocol = StreamReaderProtocol(reader) protocol = StreamReaderProtocol(reader, loop=loop)
transport, _ = yield from loop.create_connection( transport, _ = yield from loop.create_connection(
lambda: protocol, host, port, **kwds) lambda: protocol, host, port, **kwds)
writer = StreamWriter(transport, protocol, reader, loop) writer = StreamWriter(transport, protocol, reader, loop)
@ -151,7 +151,7 @@ class StreamWriter:
This exposes write(), writelines(), [can_]write_eof(), This exposes write(), writelines(), [can_]write_eof(),
get_extra_info() and close(). It adds drain() which returns an get_extra_info() and close(). It adds drain() which returns an
optional Future on which you can wait for flow control. It also 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. directly.
""" """