lib/cukeforker/worker_queue.rb in cukeforker-0.0.5 vs lib/cukeforker/worker_queue.rb in cukeforker-0.0.6

@@ -90,9 +90,14 @@
       end
 
       result
     end
 
+    def add_observer(observer)
+      @pending.each { |e| e.add_observer observer }
+      super
+    end
+
     private
 
     def start(worker)
       fire :on_worker_starting, worker