lib/zapp/worker/request_processor.rb in zapp-0.2.5 vs lib/zapp/worker/request_processor.rb in zapp-0.2.6

@@ -11,14 +11,19 @@
         @context_pipe = context_pipe
       end
 
       def loop
         while (context = context_pipe.take)
-          if context == Zapp::WorkerPool::SIGNALS[:EXIT]
-            Zapp::Logger.trace("Received exit signal, shutting down")
-            shutdown
-            break
+          if context.is_a?(Symbol)
+            if context == Zapp::WorkerPool::SIGNALS[:EXIT]
+              Zapp::Logger.trace("Received exit signal, shutting down")
+              shutdown
+              break
+            else
+              next
+            end
           end
+          
 
           process = lambda {
             process(context: context)
           }