class PhusionPassenger::UnionStation::Connection

def connected?
  return !!@channel
end

def disconnect
  @channel.close if @channel
  @channel = nil
end

def initialize(io)
  @mutex = Mutex.new
  @refcount = 1
  @channel = MessageChannel.new(io) if io
end

def ref
  @refcount += 1
end

def synchronize
  @mutex.synchronize do
    yield
  end
end

def unref
  @refcount -= 1
  if @refcount == 0
    disconnect
  end
end