Module type Command.T_pipe_direct_bin_io_only
val rpc : (query, response, error) Async.Rpc.Pipe_rpc.t
val implementation : state -> query -> response Async.Rpc.Pipe_rpc.Direct_stream_writer.t -> (unit, error) Core.Result.t Async.Deferred.t