class Async::Redis::Context::Pipeline::Sync
Public Class Methods
new(pipeline)
click to toggle source
# File lib/async/redis/context/pipeline.rb, line 36 def initialize(pipeline) @pipeline = pipeline end
Public Instance Methods
call(command, *arguments)
click to toggle source
This method just accumulates the commands and their params.
# File lib/async/redis/context/pipeline.rb, line 41 def call(command, *arguments) @pipeline.call(command, *arguments) @pipeline.flush(1) return @pipeline.read_response end