Method: Hoss::Transport::Connection::ProxyPipe::Write#initialize

Defined in:
lib/hoss/transport/connection/proxy_pipe.rb

#initialize(io, compress: true) ⇒ Write

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of Write.



43
44
45
46
47
48
49
50
51
52
 
# File 'lib/hoss/transport/connection/proxy_pipe.rb', line 43

def initialize(io, compress: true)
  @io = io
  @compress = compress
  @bytes_sent = Concurrent::AtomicFixnum.new(0)
  @config = Hoss.agent&.config # this is silly, fix Logging

  return unless compress
  enable_compression!
  ObjectSpace.define_finalizer(self, self.class.finalize(@io))
end