package lwt-pipe

You can search for identifiers within the package.

in-package search v0.2.0

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