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