diff --git a/lib/rack/attack/store_proxy/redis_proxy.rb b/lib/rack/attack/store_proxy/redis_proxy.rb index 3127de63..830d39de 100644 --- a/lib/rack/attack/store_proxy/redis_proxy.rb +++ b/lib/rack/attack/store_proxy/redis_proxy.rb @@ -32,9 +32,9 @@ def write(key, value, options = {}) def increment(key, amount, options = {}) rescuing do - pipelined do - incrby(key, amount) - expire(key, options[:expires_in]) if options[:expires_in] + pipelined do |redis| + redis.incrby(key, amount) + redis.expire(key, options[:expires_in]) if options[:expires_in] end.first end end