› Async::Redis › Source › Async › Redis › Context › Pipeline › Sync

class Sync

A synchronous wrapper for pipeline operations that executes one command at a time.

Definitions

def initialize(pipeline)

Initialize a new sync wrapper.

Signature
parameter　pipeline　Pipeline

The pipeline to wrap.

Implementation

 
def initialize(pipeline)
	@pipeline = pipeline
end

def call(...)

This method just accumulates the commands and their params.

Implementation

 
def call(...)
	@pipeline.call(...)
	
	@pipeline.flush(1)
	
	return @pipeline.read_response
end