Module Function.Direct_pipe
type nonrec ('worker, 'query, 'response) t= ('worker, 'query * ('response Async.Rpc.Pipe_rpc.Pipe_message.t -> Async.Rpc.Pipe_rpc.Pipe_response.t), Async.Rpc.Pipe_rpc.Id.t) t
Function.Direct_pipetype nonrec ('worker, 'query, 'response) t = ('worker, 'query * ('response Async.Rpc.Pipe_rpc.Pipe_message.t -> Async.Rpc.Pipe_rpc.Pipe_response.t), Async.Rpc.Pipe_rpc.Id.t) t