class RedisClient::Pipeline
Public Class Methods
new(_command_builder)
click to toggle source
Calls superclass method
RedisClient::Multi::new
# File lib/redis_client.rb, line 603 def initialize(_command_builder) super @timeouts = nil end
Public Instance Methods
_coerce!(results)
click to toggle 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
_empty?()
click to toggle source
# File lib/redis_client.rb, line 630 def _empty? @commands.empty? end
_timeouts()
click to toggle source
# File lib/redis_client.rb, line 626 def _timeouts @timeouts end
blocking_call(timeout, *command, **kwargs, &block)
click to toggle 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
blocking_call_v(timeout, command, &block)
click to toggle 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