mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
middleware upgrade (#4861)
* middleware upgrade * restore @entries init
This commit is contained in:
parent
50d0c3d2fd
commit
6a4d32e7ba
1 changed files with 5 additions and 3 deletions
|
@ -90,12 +90,12 @@ module Sidekiq
|
||||||
end
|
end
|
||||||
|
|
||||||
def add(klass, *args)
|
def add(klass, *args)
|
||||||
remove(klass) if exists?(klass)
|
remove(klass)
|
||||||
entries << Entry.new(klass, *args)
|
entries << Entry.new(klass, *args)
|
||||||
end
|
end
|
||||||
|
|
||||||
def prepend(klass, *args)
|
def prepend(klass, *args)
|
||||||
remove(klass) if exists?(klass)
|
remove(klass)
|
||||||
entries.insert(0, Entry.new(klass, *args))
|
entries.insert(0, Entry.new(klass, *args))
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@ -132,7 +132,7 @@ module Sidekiq
|
||||||
def invoke(*args)
|
def invoke(*args)
|
||||||
return yield if empty?
|
return yield if empty?
|
||||||
|
|
||||||
chain = retrieve.dup
|
chain = retrieve
|
||||||
traverse_chain = proc do
|
traverse_chain = proc do
|
||||||
if chain.empty?
|
if chain.empty?
|
||||||
yield
|
yield
|
||||||
|
@ -144,6 +144,8 @@ module Sidekiq
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
class Entry
|
class Entry
|
||||||
attr_reader :klass
|
attr_reader :klass
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue