Module: EM::Nodes::Client::TaskFeature

Defined in:
lib/em-nodes/client/task.rb

Instance Method Summary collapse

Instance Method Details

#on_task(task_id, data) ⇒ Object 



4
5
6
7
 
# File 'lib/em-nodes/client/task.rb', line 4

def on_task(task_id, data)
  # redefine me
  # after task done, should call send_task_result(task_id, result)
end

#send_task_result(task_id, result) ⇒ Object 



13
14
15
16
 
# File 'lib/em-nodes/client/task.rb', line 13

def send_task_result(task_id, result)
  send_task_result_internal(task_id, result)
  tasks.delete(task_id)
end

#tasks ⇒ Object 



9
10
11
 
# File 'lib/em-nodes/client/task.rb', line 9

def tasks
  @tasks ||= {}
end