1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00

Change &block in arguments to yield call

This commit is contained in:
Anton Davydov 2015-02-12 22:54:41 +03:00
parent 1fee12f4e4
commit 6cddc9b05a
2 changed files with 8 additions and 8 deletions

View file

@ -218,7 +218,7 @@ module Sidekiq
Time.now.to_f - Sidekiq.load_json(entry)['enqueued_at'] Time.now.to_f - Sidekiq.load_json(entry)['enqueued_at']
end end
def each(&block) def each
initial_size = size initial_size = size
deleted_size = 0 deleted_size = 0
page = 0 page = 0
@ -233,7 +233,7 @@ module Sidekiq
break if entries.empty? break if entries.empty?
page += 1 page += 1
entries.each do |entry| entries.each do |entry|
block.call Job.new(entry, @name) yield Job.new(entry, @name)
end end
deleted_size = initial_size - size deleted_size = initial_size - size
end end
@ -474,7 +474,7 @@ module Sidekiq
end end
end end
def each(&block) def each
initial_size = @_size initial_size = @_size
offset_size = 0 offset_size = 0
page = -1 page = -1
@ -489,7 +489,7 @@ module Sidekiq
break if elements.empty? break if elements.empty?
page -= 1 page -= 1
elements.each do |element, score| elements.each do |element, score|
block.call SortedEntry.new(self, score, element) yield SortedEntry.new(self, score, element)
end end
offset_size = initial_size - @_size offset_size = initial_size - @_size
end end
@ -651,7 +651,7 @@ module Sidekiq
count count
end end
def each(&block) def each
procs = Sidekiq.redis { |conn| conn.smembers('processes') }.sort procs = Sidekiq.redis { |conn| conn.smembers('processes') }.sort
Sidekiq.redis do |conn| Sidekiq.redis do |conn|
@ -760,7 +760,7 @@ module Sidekiq
class Workers class Workers
include Enumerable include Enumerable
def each(&block) def each
Sidekiq.redis do |conn| Sidekiq.redis do |conn|
procs = conn.smembers('processes') procs = conn.smembers('processes')
procs.sort.each do |key| procs.sort.each do |key|

View file

@ -120,11 +120,11 @@ module Sidekiq
entries.clear entries.clear
end end
def invoke(*args, &final_action) def invoke(*args)
chain = retrieve.dup chain = retrieve.dup
traverse_chain = lambda do traverse_chain = lambda do
if chain.empty? if chain.empty?
final_action.call yield
else else
chain.shift.call(*args, &traverse_chain) chain.shift.call(*args, &traverse_chain)
end end