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

class Pipeline

Send multiple commands without waiting for the response, instead of sending them one by one.

Nested

Definitions

def flush(count = 0)

Flush responses.

Implementation

 
def flush(count = 0)
	while @count > count
		read_response
	end
end

def write_request(*)

This method just accumulates the commands and their params.

Implementation

 
def write_request(*)
	super
	
	@count += 1
end

def call(command, *arguments)

This method just accumulates the commands and their params.

Implementation

 
def call(command, *arguments)
	write_request(command, *arguments)
	
	return nil
end