We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3a9657f commit b14ab8aCopy full SHA for b14ab8a
Lib/asyncio/streams.py
@@ -144,8 +144,7 @@ def resume_writing(self):
144
if self._loop.get_debug():
145
logger.debug("%r resumes writing", self)
146
147
- while self._drain_waiters:
148
- waiter = self._drain_waiters.popleft()
+ for waiter in self._drain_waiters:
149
if not waiter.done():
150
waiter.set_result(None)
151
@@ -155,8 +154,7 @@ def connection_lost(self, exc):
155
154
if not self._paused:
156
return
157
158
159
160
161
if exc is None:
162
0 commit comments