diff --git a/lib/sidekiq/api.rb b/lib/sidekiq/api.rb index 1348037a7..5ba5f0cfe 100644 --- a/lib/sidekiq/api.rb +++ b/lib/sidekiq/api.rb @@ -218,7 +218,7 @@ def latency Time.now.to_f - Sidekiq.load_json(entry)['enqueued_at'] end - def each(&block) + def each initial_size = size deleted_size = 0 page = 0 @@ -233,7 +233,7 @@ def each(&block) break if entries.empty? page += 1 entries.each do |entry| - block.call Job.new(entry, @name) + yield Job.new(entry, @name) end deleted_size = initial_size - size end @@ -474,7 +474,7 @@ def schedule(timestamp, message) end end - def each(&block) + def each initial_size = @_size offset_size = 0 page = -1 @@ -489,7 +489,7 @@ def each(&block) break if elements.empty? page -= 1 elements.each do |element, score| - block.call SortedEntry.new(self, score, element) + yield SortedEntry.new(self, score, element) end offset_size = initial_size - @_size end @@ -651,7 +651,7 @@ def self.cleanup count end - def each(&block) + def each procs = Sidekiq.redis { |conn| conn.smembers('processes') }.sort Sidekiq.redis do |conn| @@ -760,7 +760,7 @@ def identity class Workers include Enumerable - def each(&block) + def each Sidekiq.redis do |conn| procs = conn.smembers('processes') procs.sort.each do |key| diff --git a/lib/sidekiq/middleware/chain.rb b/lib/sidekiq/middleware/chain.rb index 47c64d0cc..2b12782ea 100644 --- a/lib/sidekiq/middleware/chain.rb +++ b/lib/sidekiq/middleware/chain.rb @@ -120,11 +120,11 @@ def clear entries.clear end - def invoke(*args, &final_action) + def invoke(*args) chain = retrieve.dup traverse_chain = lambda do if chain.empty? - final_action.call + yield else chain.shift.call(*args, &traverse_chain) end