Contents

class Redis
  class Pipeline < Redis
    BUFFER_SIZE = 50_000
    
    def initialize(redis)
      @redis = redis
      @commands = []
    end
   
    def call_command(command)
      @commands << command
    end

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

  end
end

Version data entries

8 entries across 8 versions & 4 rubygems

Version	Path
vanity-1.3.0	vendor/redis-rb/lib/pipeline.rb
mikeg-vanity-1.3.0	vendor/redis-rb/lib/pipeline.rb
redis-0.1.2	lib/pipeline.rb
kali-redis-0.1.1	lib/pipeline.rb
vanity-1.2.0	vendor/redis-rb/lib/pipeline.rb
vanity-1.1.1	vendor/redis-rb/lib/pipeline.rb
vanity-1.1.0	vendor/redis-rb/lib/pipeline.rb
redis-0.1.1	lib/pipeline.rb