class Redis::Pipeline
def call(*args)
Starting with 2.2.1, assume that this method is called with a single
def call(*args) if args.first.is_a?(Array) && args.size == 1 command = args.first else command = args end @commands << command nil end
def call_pipelined(commands, options = {})
def call_pipelined(commands, options = {}) @commands.concat commands nil end
def call_without_reply(command)
Assume that this method is called with a single array argument. No
def call_without_reply(command) @commands.push command nil end
def initialize
def initialize @commands = [] end