class Async::Container::Supervisor::Connection::Call
def initialize(connection, id, message)
def initialize(connection, id, message) @connection = connection @id = id @message = message @queue = ::Thread::Queue.new end
def initialize(connection, id, message) @connection = connection @id = id @message = message @queue = ::Thread::Queue.new end