class RedisClient::Pipeline
Public Class Methods
Source
# File lib/redis_client.rb, line 603 def initialize(_command_builder) super @timeouts = nil end
Calls superclass method
RedisClient::Multi::new
Public Instance Methods
Source
# File lib/redis_client.rb, line 634 def _coerce!(results) return results unless results @blocks&.each_with_index do |block, index| if block results[index] = block.call(results[index]) end end results end
Source
# File lib/redis_client.rb, line 608 def blocking_call(timeout, *command, **kwargs, &block) command = @command_builder.generate(command, kwargs) @timeouts ||= [] @timeouts[@commands.size] = timeout (@blocks ||= [])[@commands.size] = block if block_given? @commands << command nil end
Source
# File lib/redis_client.rb, line 617 def blocking_call_v(timeout, command, &block) command = @command_builder.generate(command) @timeouts ||= [] @timeouts[@commands.size] = timeout (@blocks ||= [])[@commands.size] = block if block_given? @commands << command nil end