class Redis::Pipeline

def call_command(command)
  @commands << command
end

def execute
  return if @commands.empty?
  @redis.call_command(@commands)
  @commands.clear
end

def initialize(redis)
  @redis = redis
  @commands = []
end