class ElasticAPM::Transport::Connection::ProxyPipe::Write

def initialize(io, compress: true)
  @io = io
  @compress = compress
  @bytes_sent = Concurrent::AtomicFixnum.new(0)
  @config = ElasticAPM.agent&.config # this is silly, fix Logging
  return unless compress
  enable_compression!
end