Module Pipe.MakeSource

Parameters

module M : Monad

Signature

Sourcetype 'a monad = 'a M.t
Sourcetype 'a thunk = unit -> 'a
Sourcetype finalizer = (unit -> unit monad) option
Sourcetype ('i, 'o, 'r) t =
  1. | Has_output of 'o * ('i, 'o, 'r) t thunk * finalizer
  2. | Needs_input of 'i option -> ('i, 'o, 'r) t
  3. | Done of 'r
  4. | PipeM of ('i, 'o, 'r) t monad thunk
Sourcetype 'a source = (void, 'a, unit) t
Sourcetype 'a sink = ('a, void, unit) t
Sourceval return : 'r -> (_, _, 'r) t
Sourceval bind : ('i, 'o, 'a) t -> ('a -> ('i, 'o, 'b) t) -> ('i, 'o, 'b) t
Sourcemodule Monad_infix : sig ... end
Sourceval await : unit -> ('a, _, 'a option) t
Sourceval yield : 'o -> (_, 'o, unit) t
Sourceval compose : ('i, 'a, _) t -> ('a, 'o, 'r) t -> ('i, 'o, 'r) t
Sourceval ($$) : ('i, 'a, _) t -> ('a, 'o, 'r) t -> ('i, 'o, 'r) t
Sourceval run : (void, void, 'r) t -> 'r monad
Sourceval bracket : (unit -> 'a monad) -> ('a -> unit monad) -> ('a -> ('i, 'o, 'r) t) -> ('i, 'o, 'r) t
Sourceval fold : 'r -> ('i -> 'r -> 'r) -> ('i, void, 'r) t
Sourceval map : ('i -> 'o) -> ('i, 'o, unit) t
Sourceval mapi : (int -> 'i -> 'o) -> ('i, 'o, unit) t
Sourceval filter : ('i -> bool) -> ('i, 'i, unit) t
Sourceval filter_map : ('i -> 'o option) -> ('i, 'o, unit) t
Sourceval from_list : 'a list -> 'a source
Sourceval to_list : unit -> ('a, void, 'a list) t
Sourceval all : unit -> (('a, 'b) result, void, ('a list, 'b) result) t
Sourceval loop : ('a -> 'b option -> 'a * 'c list) -> 'a -> ('b, 'c, unit) t
Sourceval loop' : ('a -> 'b option -> ('a * 'c list, 'd) result) -> 'a -> ('b, 'c, (unit, 'd) result) t
Sourceval drop : int -> ('a, 'a, unit) t