lib/stream.mli

   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