class Sidekiq::Middleware::Chain

Public Class Methods

new() { |self| ... } click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 79
def initialize
  @entries = nil
  yield self if block_given?
end

Public Instance Methods

add(klass, *args) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 92
def add(klass, *args)
  remove(klass)
  entries << Entry.new(klass, *args)
end
clear() click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 128
def clear
  entries.clear
end
each(&block) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 75
def each(&block)
  entries.each(&block)
end
empty?() click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 120
def empty?
  @entries.nil? || @entries.empty?
end
entries() click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 84
def entries
  @entries ||= []
end
exists?(klass) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 116
def exists?(klass)
  any? { |entry| entry.klass == klass }
end
initialize_copy(copy) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 71
def initialize_copy(copy)
  copy.instance_variable_set(:@entries, entries.dup)
end
insert_after(oldklass, newklass, *args) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 109
def insert_after(oldklass, newklass, *args)
  i = entries.index { |entry| entry.klass == newklass }
  new_entry = i.nil? ? Entry.new(newklass, *args) : entries.delete_at(i)
  i = entries.index { |entry| entry.klass == oldklass } || entries.count - 1
  entries.insert(i + 1, new_entry)
end
insert_before(oldklass, newklass, *args) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 102
def insert_before(oldklass, newklass, *args)
  i = entries.index { |entry| entry.klass == newklass }
  new_entry = i.nil? ? Entry.new(newklass, *args) : entries.delete_at(i)
  i = entries.index { |entry| entry.klass == oldklass } || 0
  entries.insert(i, new_entry)
end
invoke(*args) { || ... } click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 132
def invoke(*args)
  return yield if empty?

  chain = retrieve
  traverse_chain = proc do
    if chain.empty?
      yield
    else
      chain.shift.call(*args, &traverse_chain)
    end
  end
  traverse_chain.call
end
prepend(klass, *args) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 97
def prepend(klass, *args)
  remove(klass)
  entries.insert(0, Entry.new(klass, *args))
end
remove(klass) click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 88
def remove(klass)
  entries.delete_if { |entry| entry.klass == klass }
end
retrieve() click to toggle source
# File lib/sidekiq/middleware/chain.rb, line 124
def retrieve
  map(&:make_new)
end