Method: Packet::Connection#ask_worker

Defined in:
lib/packet/packet_connection.rb

#ask_worker(*args) ⇒ Object

Raises:



47
48
49
50
51
52
53
54
 
# File 'lib/packet/packet_connection.rb', line 47

def ask_worker(*args)
  worker_name = args.shift
  data_options = args.last
  data_options[:client_signature] = connection.fileno
  t_worker = reactor.live_workers[worker_name]
  raise Packet::InvalidWorker.new("Invalid worker with name #{worker_name} and key #{data_options[:data][:worker_key]}") unless t_worker
  t_worker.send_request(data_options)
end