class Redis::PipelinedConnection

Public Class Methods

new(pipeline) click to toggle source
# File lib/redis/pipeline.rb, line 7
def initialize(pipeline)
  @pipeline = pipeline
end

Public Instance Methods

call_pipeline(pipeline) click to toggle source
# File lib/redis/pipeline.rb, line 25
def call_pipeline(pipeline)
  @pipeline.call_pipeline(pipeline)
  nil
end
db() click to toggle source
# File lib/redis/pipeline.rb, line 13
def db
  @pipeline.db
end
db=(db) click to toggle source
# File lib/redis/pipeline.rb, line 17
def db=(db)
  @pipeline.db = db
end
pipelined() { |self| ... } click to toggle source
# File lib/redis/pipeline.rb, line 21
def pipelined
  yield self
end

Private Instance Methods

send_blocking_command(command, timeout, &block) click to toggle source
# File lib/redis/pipeline.rb, line 40
def send_blocking_command(command, timeout, &block)
  @pipeline.call_with_timeout(command, timeout, &block)
end
send_command(command, &block) click to toggle source
# File lib/redis/pipeline.rb, line 36
def send_command(command, &block)
  @pipeline.call(command, &block)
end
synchronize() { |self| ... } click to toggle source
# File lib/redis/pipeline.rb, line 32
def synchronize
  yield self
end