Module: RedisPipeliner

Defined in:
lib/redis_pipeliner.rb,
lib/redis_pipeliner/version.rb,
lib/redis_pipeliner/pipeliner.rb

Defined Under Namespace

Classes: Pipeliner

Constant Summary collapse

VERSION = 
"0.0.2"

Class Method Summary collapse

Class Method Details

.pipeline(redis, &proc) ⇒ Object

Convenience for creating a pipeline, enqueueing, and blocking until the results are processed.



8
9
10
11
12
13
14
15
 
# File 'lib/redis_pipeliner.rb', line 8

def pipeline(redis, &proc)
  pipeliner = RedisPipeliner::Pipeliner.new(redis)
  redis.pipelined do
    proc.call pipeliner
  end

  pipeliner.values
end