Up

Module Safe_pipe

Alternatives to appropriate Pipe.* functions that would catch exceptions raised by transformation functions and convert them to Errors on the output pipe, closing it afterwards. Contract is that if there is Error it would be the last element on the pipe.

If die_on_error is set, Shutdown would be called immediately if we encounter an error.

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