# File lib/nanite/job.rb, line 72 def process(msg) case msg when Result results[msg.from] = msg.results targets.delete(msg.from) when IntermediateMessage intermediate_state[msg.from] ||= {} intermediate_state[msg.from][msg.messagekey] ||= [] intermediate_state[msg.from][msg.messagekey] << msg.message @pending_keys << msg.messagekey end end