lib/rocket_job/subscribers/server.rb in rocketjob-5.4.1 vs lib/rocket_job/subscribers/server.rb in rocketjob-6.0.0.rc1

@@ -15,10 +15,10 @@
         supervisor.synchronize do
           Supervisor.shutdown!
 
           supervisor.logger.info("Stopping Pool")
           supervisor.worker_pool.stop
-          unless supervisor.worker_pool.living_count == 0
+          unless supervisor.worker_pool.living_count.zero?
             supervisor.logger.info("Giving pool #{wait_timeout} seconds to terminate")
             sleep(wait_timeout)
           end
           supervisor.logger.info("Kill Pool")
           supervisor.worker_pool.kill