Module Biotk_pipes_unix.PipeSource

include Biotk_pipes.Pipe.S with type 'a monad = 'a
type 'a monad = 'a
type 'a thunk = unit -> 'a
type finalizer = (unit -> unit monad) option
type ('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
type 'a source = (Biotk_pipes.Pipe.void, 'a, unit) t
type 'a sink = ('a, Biotk_pipes.Pipe.void, unit) t
val return : 'r -> (_, _, 'r) t
val bind : ('i, 'o, 'a) t -> ('a -> ('i, 'o, 'b) t) -> ('i, 'o, 'b) t
module Monad_infix : sig ... end
val await : unit -> ('a, _, 'a option) t
val yield : 'o -> (_, 'o, unit) t
val compose : ('i, 'a, _) t -> ('a, 'o, 'r) t -> ('i, 'o, 'r) t
val ($$) : ('i, 'a, _) t -> ('a, 'o, 'r) t -> ('i, 'o, 'r) t
val bracket : (unit -> 'a monad) -> ('a -> unit monad) -> ('a -> ('i, 'o, 'r) t) -> ('i, 'o, 'r) t
val fold : 'r -> ('i -> 'r -> 'r) -> ('i, Biotk_pipes.Pipe.void, 'r) t
val map : ('i -> 'o) -> ('i, 'o, unit) t
val mapi : (int -> 'i -> 'o) -> ('i, 'o, unit) t
val filter : ('i -> bool) -> ('i, 'i, unit) t
val filter_map : ('i -> 'o option) -> ('i, 'o, unit) t
val from_list : 'a list -> 'a source
val to_list : unit -> ('a, Biotk_pipes.Pipe.void, 'a list) t
val all : unit -> (('a, 'b) result, Biotk_pipes.Pipe.void, ('a list, 'b) result) t
val loop : ('a -> 'b option -> 'a * 'c list) -> 'a -> ('b, 'c, unit) t
val loop' : ('a -> 'b option -> ('a * 'c list, 'd) result) -> 'a -> ('b, 'c, (unit, 'd) result) t
val drop : int -> ('a, 'a, unit) t
Sourceval from_file : ?buffer_size:int -> string -> string source
Sourceval to_file : string -> string sink