Up

Module Run_in_fork

Signature

val run_in_fork : ?max_len:int -> bin_t:'b Core.Std.Bin_prot.Type_class.t -> f:(unit -> 'b) -> unit -> 'b Core.Std.Or_error.t Async.Std.Deferred.t
type 'a ret =
| Part of 'a
| Err of Core.Std.Error.t
| Done
val run_in_fork_multiple : ?max_len:int -> bin_t:'b Core.Std.Bin_prot.Type_class.t -> f:(write:('b -> unit) -> unit) -> unit -> 'b ret Async.Std.Pipe.Reader.t