Module type Command.T_pipe_direct_bin_io_only

type query
type response
type error
type state
val rpc : (queryresponseerror) 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