parList package:streamly

Like parConcat but works on a list of streams.

>>> parList modifier = Stream.parConcat modifier . Stream.fromList

Like parListLazy but with eager on.

>>> parListEager = Stream.parList (Stream.eager True)

Like parListEager but stops the output as soon as the first stream stops.

>>> parListEagerFst = Stream.parList (Stream.eager True . Stream.stopWhen Stream.FirstStops)

Like parListEager but stops the output as soon as any of the two streams stops. Definition:

>>> parListEagerMin = Stream.parList (Stream.eager True . Stream.stopWhen Stream.AnyStops)

Like parListLazy but interleaves the streams fairly instead of prioritizing the left stream. This schedules all streams in a round robin fashion over limited number of threads.

>>> parListInterleaved = Stream.parList (Stream.interleaved True)

Like concat but works on a list of streams.

>>> parListLazy = Stream.parList id

Like parListLazy but with ordered on.

>>> parListOrdered = Stream.parList (Stream.ordered True)