[dups.git] / lib / stream.mli

type 'a t

val create : (unit -> 'a option) -> 'a t

val of_queue : 'a Queue.t -> 'a t

val iter : 'a t -> f:('a -> unit) -> unit

val bag_map : 'a t -> njobs:int -> f:('a -> 'b) -> ('a * 'b) t
(** Parallel map with arbitrarily-reordered elements. *)

val map : 'a t -> f:('a -> 'b) -> 'b t

val filter : 'a t -> f:('a -> bool) -> 'a t

val concat : ('a t) list -> 'a t

val group_by : 'a t -> f:('a -> 'b) -> ('b * int * 'a list) t
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