type ('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