class ElasticAPM::Transport::Connection::ProxyPipe

@api private

def self.pipe(**args) 

def self.pipe(**args)
  pipe = new(**args)
  [pipe.read, pipe.write]
end

def initialize(enc = nil, compress: true) 

def initialize(enc = nil, compress: true)
  rd, wr = IO.pipe(enc)
  @read = rd
  @write = Write.new(wr, compress: compress)
  # Http.rb<4 calls rewind on the request bodies, but IO::Pipe raises
  # ~mikker
  return if HTTP::VERSION.to_i >= 4
  def rd.rewind; end
end