summaryrefslogtreecommitdiffstats
path: root/Lib/asyncio/streams.py
diff options
context:
space:
mode:
authorYury Selivanov <yselivanov@sprymix.com>2016-05-16 19:39:39 (GMT)
committerYury Selivanov <yselivanov@sprymix.com>2016-05-16 19:39:39 (GMT)
commit8ace2c66d35cf4cbb2d4a6383e33c0bb96448ecb (patch)
treea4d780ee11c4d8732b927c8271eb5427428fb39c /Lib/asyncio/streams.py
parent7c3ac2d1f82ed44a90de34d5bc6424c64b19ce68 (diff)
parent7661db622892c9731c502ccdd7af130cbfd23f5c (diff)
downloadcpython-8ace2c66d35cf4cbb2d4a6383e33c0bb96448ecb.zip
cpython-8ace2c66d35cf4cbb2d4a6383e33c0bb96448ecb.tar.gz
cpython-8ace2c66d35cf4cbb2d4a6383e33c0bb96448ecb.tar.bz2
Merge 3.5 (Issue #27041)
Diffstat (limited to 'Lib/asyncio/streams.py')
-rw-r--r--Lib/asyncio/streams.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/Lib/asyncio/streams.py b/Lib/asyncio/streams.py
index b7b0485..da3d526 100644
--- a/Lib/asyncio/streams.py
+++ b/Lib/asyncio/streams.py
@@ -210,7 +210,7 @@ class FlowControlMixin(protocols.Protocol):
return
waiter = self._drain_waiter
assert waiter is None or waiter.cancelled()
- waiter = futures.Future(loop=self._loop)
+ waiter = self._loop.create_future()
self._drain_waiter = waiter
yield from waiter
@@ -449,7 +449,7 @@ class StreamReader:
self._paused = False
self._transport.resume_reading()
- self._waiter = futures.Future(loop=self._loop)
+ self._waiter = self._loop.create_future()
try:
yield from self._waiter
finally: