mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Remove unused vars
This commit is contained in:
parent
299ed69ea5
commit
f0bbbf9035
4 changed files with 3 additions and 6 deletions
|
@ -123,7 +123,7 @@ module Sidekiq
|
|||
conn.multi {
|
||||
queues.map { |q| conn.llen("queue:#{q}") }
|
||||
}
|
||||
}.inject(0) { |memo, count| memo += count }
|
||||
}.inject(0) { |memo, count| memo + count }
|
||||
end
|
||||
|
||||
end
|
||||
|
|
|
@ -6,7 +6,7 @@ module Sidekiq
|
|||
class Client
|
||||
|
||||
def self.default_middleware
|
||||
Middleware::Chain.new do |m|
|
||||
Middleware::Chain.new do
|
||||
end
|
||||
end
|
||||
|
||||
|
@ -64,7 +64,6 @@ module Sidekiq
|
|||
payload
|
||||
end.compact
|
||||
|
||||
pushed = false
|
||||
pushed = raw_push(normed, payloads)
|
||||
pushed ? payloads.size : nil
|
||||
end
|
||||
|
|
|
@ -272,7 +272,7 @@ class TestApi < MiniTest::Unit::TestCase
|
|||
it 'can enumerate workers' do
|
||||
w = Sidekiq::Workers.new
|
||||
assert_equal 0, w.size
|
||||
w.each do |x, y|
|
||||
w.each do
|
||||
assert false
|
||||
end
|
||||
|
||||
|
|
|
@ -125,12 +125,10 @@ class TestClient < MiniTest::Unit::TestCase
|
|||
Sidekiq::Queue.new.clear
|
||||
end
|
||||
it 'can push a large set of jobs at once' do
|
||||
a = Time.now
|
||||
count = Sidekiq::Client.push_bulk('class' => QueuedWorker, 'args' => (1..1_000).to_a.map { |x| Array(x) })
|
||||
assert_equal 1_000, count
|
||||
end
|
||||
it 'can push a large set of jobs at once using a String class' do
|
||||
a = Time.now
|
||||
count = Sidekiq::Client.push_bulk('class' => 'QueuedWorker', 'args' => (1..1_000).to_a.map { |x| Array(x) })
|
||||
assert_equal 1_000, count
|
||||
end
|
||||
|
|
Loading…
Add table
Reference in a new issue