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