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.
test_map_buffersize_on_multiple_infinite_iterables
1 parent b2bd1ad commit 40c0318Copy full SHA for 40c0318
Lib/test/test_concurrent_futures/executor.py
@@ -110,7 +110,17 @@ def test_map_buffersize_on_infinite_iterable(self):
110
self.assertEqual(next(res, None), "0")
111
self.assertEqual(next(res, None), "1")
112
self.assertEqual(next(res, None), "2")
113
- self.assertEqual(next(res, None), "3")
+
114
+ def test_map_buffersize_on_multiple_infinite_iterables(self):
115
+ res = self.executor.map(
116
+ add,
117
+ itertools.count(),
118
119
+ buffersize=2
120
+ )
121
+ self.assertEqual(next(res, None), 0)
122
+ self.assertEqual(next(res, None), 2)
123
+ self.assertEqual(next(res, None), 4)
124
125
def test_map_buffersize_on_empty_iterable(self):
126
res = self.executor.map(str, [], buffersize=2)
0 commit comments