lib/sidekiq/limit_fetch/local/semaphore.rb in sidekiq-limit_fetch-0.7 vs lib/sidekiq/limit_fetch/local/semaphore.rb in sidekiq-limit_fetch-0.8
- old
+ new
@@ -30,10 +30,26 @@
def pause
@paused = true
end
- def continue
+ def unpause
@paused = false
+ end
+
+ def paused?
+ @paused
+ end
+
+ def block
+ @block = true
+ end
+
+ def unblock
+ @block = false
+ end
+
+ def blocking?
+ @block
end
end
end