Up

Module Safe_pipe

Signature

val wrap_ok : 'a Async.Std.Pipe.Reader.t -> 'a Core.Std.Or_error.t Async.Std.Pipe.Reader.t

val transfer : 'a Core.Std.Or_error.t Async.Std.Pipe.Reader.t -> 'b Core.Std.Or_error.t Async.Std.Pipe.Writer.t -> f:('a -> 'b) -> unit Async.Std.Deferred.t

val map : 'a Core.Std.Or_error.t Async.Std.Pipe.Reader.t -> f:('a -> 'b) -> 'b Core.Std.Or_error.t Async.Std.Pipe.Reader.t

val filter_map : 'a Core.Std.Or_error.t Async.Std.Pipe.Reader.t -> f:('a -> 'b option) -> 'b Core.Std.Or_error.t Async.Std.Pipe.Reader.t

val filter : 'a Core.Std.Or_error.t Async.Std.Pipe.Reader.t -> f:('a -> bool) -> 'a Core.Std.Or_error.t Async.Std.Pipe.Reader.t