We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 342a962 commit 30d8a50Copy full SHA for 30d8a50
1 file changed
tests/_streams/test_stream_converter.py
@@ -58,5 +58,5 @@ def test_convert_to_sequential_stream_parallel_numeric(self):
58
("sequential numeric stream", SequentialNumericStream)])
59
def test_convert_sequential_to_parallel_parallelizer_working(self, _, stream):
60
res = []
61
- stream([1, 2, 3]).parallel().filter(lambda x: x > 1).for_each(lambda x: res.append(x))
+ stream([1, 2, 3]).parallel().filter(lambda x: x > 1).for_each(res.append)
62
self.assertEqual(res, [2, 3])
0 commit comments