From d89bbca6ed073c8a10116dc398213a31eb568008 Mon Sep 17 00:00:00 2001 From: Mathieu Jobin Date: Sat, 3 Jun 2023 06:56:47 +0900 Subject: [PATCH] rename with with run_with --- lib/redlock/client.rb | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/lib/redlock/client.rb b/lib/redlock/client.rb index f538eeb..dde4cde 100644 --- a/lib/redlock/client.rb +++ b/lib/redlock/client.rb @@ -148,13 +148,13 @@ def valid_lock?(lock_info) class RedisInstance module ConnectionPoolLike - def with + def run_with yield self end end def initialize(connection) - if connection.respond_to?(:with) + if connection.respond_to?(:run_with) @redis = connection else if connection.respond_to?(:client) @@ -168,7 +168,7 @@ def initialize(connection) def lock(resource, val, ttl, allow_new_lock) recover_from_script_flush do - @redis.with { |conn| + @redis.run_with { |conn| conn.call('EVALSHA', Scripts::LOCK_SCRIPT_SHA, 1, resource, val, ttl, allow_new_lock) } end @@ -176,7 +176,7 @@ def lock(resource, val, ttl, allow_new_lock) def unlock(resource, val) recover_from_script_flush do - @redis.with { |conn| + @redis.run_with { |conn| conn.call('EVALSHA', Scripts::UNLOCK_SCRIPT_SHA, 1, resource, val) } end @@ -186,7 +186,7 @@ def unlock(resource, val) def get_remaining_ttl(resource) recover_from_script_flush do - @redis.with { |conn| + @redis.run_with { |conn| conn.call('EVALSHA', Scripts::PTTL_SCRIPT_SHA, 1, resource) } end @@ -203,7 +203,7 @@ def load_scripts Scripts::PTTL_SCRIPT ] - @redis.with do |connnection| + @redis.run_with do |connnection| scripts.each do |script| connnection.call('SCRIPT', 'LOAD', script) end