package lwt-pipe

  1. Overview
  2. Docs
package lwt-pipe
Legend:
Library
Module
Module type
Parameter
Class
Class type
type 'a t = ('a, [ `r ]) pipe
val map : f:('a -> 'b) -> ('a, [> `r ]) pipe -> 'b t
val map_s : f:('a -> 'b Lwt.t) -> ('a, [> `r ]) pipe -> 'b t
val filter : f:('a -> bool) -> ('a, [> `r ]) pipe -> 'a t
val filter_map : f:('a -> 'b option) -> ('a, [> `r ]) pipe -> 'b t
val filter_map_s : f:('a -> 'b option Lwt.t) -> ('a, [> `r ]) pipe -> 'b t
val flat_map : f:('a -> 'b list) -> ('a, [> `r ]) pipe -> 'b t
val flat_map_s : f:('a -> 'b list Lwt.t) -> ('a, [> `r ]) pipe -> 'b t
val fold : f:('acc -> 'a -> 'acc) -> x:'acc -> ('a, [> `r ]) pipe -> 'acc Lwt.t
val fold_s : f:('acc -> 'a -> 'acc Lwt.t) -> x:'acc -> ('a, [> `r ]) pipe -> 'acc Lwt.t
val iter : f:('a -> unit) -> ('a, [> `r ]) pipe -> unit Lwt.t
val iter_s : f:('a -> unit Lwt.t) -> ('a, [> `r ]) pipe -> unit Lwt.t
val iter_p : f:('a -> unit Lwt.t) -> ('a, [> `r ]) pipe -> unit Lwt.t
val merge_both : ('a, [> `r ] as 'kind) pipe -> ('a, [> `r ] as 'kind) pipe -> 'a t

Merge the two input streams in a non-specified order

val merge_all : ('a, [> `r ]) pipe list -> 'a t

Merge all the input streams

val append : ('a, [> `r ]) pipe -> ('a, [> `r ]) pipe -> 'a t

append a b reads from a until a closes, then reads from b and closes when b closes