Fix worker's inline running mode

It's quite useful for tests.

Author: rosa

app/models/solid_queue/ready_execution.rb

@@ -15,6 +15,10 @@ def claim(queue_list, limit, process_id)
         end
       end
 
+      def aggregated_count_across(queue_list)
+        QueueSelector.new(queue_list, self).scoped_relations.map(&:count).sum
+      end
+
       private
         def select_and_lock(queue_relation, process_id, limit)
           return [] if limit <= 0

lib/solid_queue/processes/runnable.rb

@@ -4,6 +4,8 @@ module SolidQueue::Processes
   module Runnable
     include Supervised
 
+    attr_writer :mode
+
     def start
       @stopping = false
 
@@ -19,8 +21,6 @@ def stop
     end
 
   private
-    attr_writer :mode
-
     DEFAULT_MODE = :async
 
     def mode

lib/solid_queue/worker.rb

@@ -44,7 +44,7 @@ def shutdown
       end
 
       def all_work_completed?
-        SolidQueue::ReadyExecution.queued_as(queues).empty?
+        SolidQueue::ReadyExecution.aggregated_count_across(queues).zero?
       end
 
       def metadata

test/unit/worker_test.rb

@@ -89,4 +89,15 @@ class WorkerTest < ActiveSupport::TestCase
     ActiveRecord::Base.logger = old_logger
     SolidQueue.silence_polling = old_silence_polling
   end
+
+  test "run inline" do
+    worker = SolidQueue::Worker.new(queues: "*", threads: 3, polling_interval: 0.2)
+    worker.mode = :inline
+
+    5.times { |i| StoreResultJob.perform_later(:immediate) }
+
+    worker.start
+
+    assert_equal 5, JobResult.where(queue_name: :background, status: "completed", value: :immediate).count
+  end
 end