2018-10-23 13:39:06 +02:00
|
|
|
(** The Farm skeleton, similar to SklMl.
|
|
|
|
|
|
|
|
|
|
The input is a stream of input data, and the output is a stream of data.
|
|
|
|
|
*)
|
|
|
|
|
|
|
|
|
|
|
2019-04-04 09:14:15 +02:00
|
|
|
val run : ?ordered:bool -> ?comm:'c ->
|
|
|
|
|
f:('a -> 'b) -> 'a Stream.t -> 'b Stream.t
|
2018-10-23 13:39:06 +02:00
|
|
|
(** Run the [f] function on every process by popping elements from the
|
|
|
|
|
input stream, and putting the results on the output stream. If [ordered]
|
|
|
|
|
(the default is [ordered = true], then the order of the output is kept
|
|
|
|
|
consistent with the order of the input.
|
2019-04-04 09:14:15 +02:00
|
|
|
In the non-parallel mode, the [comm] argument is unused.
|
2018-10-23 13:39:06 +02:00
|
|
|
*)
|
|
|
|
|
|
|
|
|
|
|
