Commit | Line | Data |
---|---|---|
ddcbda00 SK |
1 | type 'a t |
2 | ||
3 | val create : (unit -> 'a option) -> 'a t | |
4 | ||
5 | val of_queue : 'a Queue.t -> 'a t | |
6 | ||
7 | val iter : 'a t -> f:('a -> unit) -> unit | |
8 | ||
9 | val bag_map : 'a t -> njobs:int -> f:('a -> 'b) -> ('a * 'b) t | |
10 | (** Parallel map with arbitrarily-reordered elements. *) | |
11 | ||
12 | val map : 'a t -> f:('a -> 'b) -> 'b t | |
13 | ||
14 | val filter : 'a t -> f:('a -> bool) -> 'a t | |
15 | ||
16 | val concat : ('a t) list -> 'a t | |
17 | ||
18 | val group_by : 'a t -> f:('a -> 'b) -> ('b * int * 'a list) t |