lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.6.0 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.6.1

@@ -53,14 +53,18 @@
       false
     end
 
     def do_loop
       catch(:done) do
-        loop do
+        while keep_going?
           throw :done unless @continue
           yield
         end
       end
+    end
+
+    def keep_going?
+      true
     end
 
     def handle_next_queue_item
       queue.pop do |message|
         dispatch_message(message)