Async::RedisSourceAsyncRedisProtocolRESP2Connection

class Connection

A connection implementation for RESP2 protocol.

Definitions

def concurrency

Get the concurrency level for this connection.

Signature

returns Integer

The concurrency level (1 for RESP2).

Implementation

def concurrency
	1
end

def viable?

Check if the connection is viable for use.

Signature

returns Boolean

True if the stream is readable.

Implementation

def viable?
	@stream.readable?
end

def reusable?

Check if the connection can be reused.

Signature

returns Boolean

True if the stream is not closed.

Implementation

def reusable?
	!@stream.closed?
end