lib/invoker/reactor/reader.rb in invoker-1.2.0.pre vs lib/invoker/reactor/reader.rb in invoker-1.2.0.pre1

@@ -17,9 +17,10 @@
 
     private
 
     def process_read(ready_fd)
       command_worker = Invoker.commander.get_worker_from_fd(ready_fd)
+      return unless command_worker
       begin
         data = read_data(ready_fd)
         command_worker.receive_data(data)
       rescue Invoker::Errors::ProcessTerminated
         remove_from_read_monitoring(command_worker.pipe_end, command_worker)