Skip to content

Commit

Permalink
edit commit
Browse files Browse the repository at this point in the history
  • Loading branch information
www committed Feb 23, 2024
1 parent 1449b53 commit 1d9d475
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions tests/_parallel/test_parallel_stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,18 +6,18 @@

class TestParallelStream(TestCase):
def test_parallel(self):
# success 0
# success
(Stream.of(range(10)).parallel()
.map(lambda x: x * 2)
.for_each(print))

# success 1
# success
(Stream.parallel_of(range(10))
.map(lambda x: x * 2)
.filter(prime())
.for_each(print))

# failed
# fail -> fixed
(Stream.of(range(10)).parallel()
.map(lambda x: x * 2)
.filter(prime())
Expand Down

0 comments on commit 1d9d475

Please sign in to comment.