Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://socketry.github.io/async-redis/source/Async/Redis/Context/Pipeline/index.html below:

Async::Redis::Context::Pipeline

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

Initialize a new pipeline context.

parameter　pool　Pool

The connection pool to use.

def initialize(pool)
	super(pool)
	
	@count = 0
	@sync = nil
end

Flush responses.

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

Collect all pending responses.

yields　{...}

Optional block to execute while collecting responses.

returns　Array

Array of all responses if no block given.

def collect
	if block_given?
		flush
		yield
	end
	
	@count.times.map{read_response}
end

Get a synchronous wrapper for this pipeline.

returns　Sync

A synchronous wrapper that executes commands immediately.

def sync
	@sync ||= Sync.new(self)
end

This method just accumulates the commands and their params.

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

This method just accumulates the commands and their params.

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

Read a response from the pipeline.

returns　Object

The next response in the pipeline.

def read_response
	if @count > 0
		@count -= 1
		super
	else
		raise RuntimeError, "No more responses available!"
	end
end

Close the pipeline and flush all pending responses.

def close
	flush
ensure
	super
end

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4