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 de09aff commit 1814bfeCopy full SHA for 1814bfe
1 file changed
Lib/concurrent/futures/_base.py
@@ -629,21 +629,21 @@ def result_iterator():
629
fs.reverse()
630
# Careful not to keep a reference to the popped future or its result
631
while fs:
632
- # wait for the next result
+ # Wait for the next result
633
if timeout is None:
634
_result_or_cancel(fs[-1])
635
else:
636
_result_or_cancel(fs[-1], end_time - time.monotonic())
637
638
- # buffer next task
+ # Buffer next task
639
if (
640
buffersize
641
and (executor := executor_weakref())
642
and (args := next(zipped_iterables, None))
643
):
644
fs.appendleft(executor.submit(fn, *args))
645
646
- # yield the awaited result
+ # Yield the awaited result
647
yield fs.pop().result()
648
finally:
649
for future in fs:
0 commit comments