Sha256: 8299d5c33c78e06c3ec7cbda8a085a2e88a85785d1b39567b9b5584ad760d273
Contents?: true
Size: 831 Bytes
Versions: 11
Compression:
Stored size: 831 Bytes
Contents
# frozen_string_literal: true
class RedisClient
module ConnectionMixin
def call(command, timeout)
write(command)
result = read(timeout)
if result.is_a?(CommandError)
result._set_command(command)
raise result
else
result
end
end
def call_pipelined(commands, timeouts)
exception = nil
size = commands.size
results = Array.new(commands.size)
write_multi(commands)
size.times do |index|
timeout = timeouts && timeouts[index]
result = read(timeout)
if result.is_a?(CommandError)
result._set_command(commands[index])
exception ||= result
end
results[index] = result
end
if exception
raise exception
else
results
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems