Struct redis::aio::MultiplexedConnection

pub struct MultiplexedConnection { /* private fields */ }

Available on crate feature aio only.

A connection object which can be cloned, allowing requests to be be sent concurrently on the same underlying connection (tcp/unix socket).

Implementations

impl MultiplexedConnection

pub async fn new<C>( connection_info: &RedisConnectionInfo, stream: C ) -> RedisResult<(Self, impl Future<Output = ()>)>where C: Unpin + AsyncRead + AsyncWrite + Send + 'static,

Constructs a new MultiplexedConnection out of a AsyncRead + AsyncWrite object and a ConnectionInfo

pub async fn send_packed_command(&mut self, cmd: &Cmd) -> RedisResult<Value>

Sends an already encoded (packed) command into the TCP socket and reads the single response from it.

pub async fn send_packed_commands( &mut self, cmd: &Pipeline, offset: usize, count: usize ) -> RedisResult<Vec<Value>>

Sends multiple already encoded (packed) command into the TCP socket and reads count responses from it. This is used to implement pipelining.

Trait Implementations

impl Clone for MultiplexedConnection

fn clone(&self) -> MultiplexedConnection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Connect for MultiplexedConnection

fn connect<'a, T>(info: T) -> RedisFuture<'a, MultiplexedConnection>where T: IntoConnectionInfo + Send + 'a,

Connect to a node, returning handle for command execution.

impl ConnectionLike for MultiplexedConnection

fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>

Sends an already encoded (packed) command into the TCP socket and reads the single response from it.

fn req_packed_commands<'a>( &'a mut self, cmd: &'a Pipeline, offset: usize, count: usize ) -> RedisFuture<'a, Vec<Value>>

Sends multiple already encoded (packed) command into the TCP socket and reads count responses from it. This is used to implement pipelining.

fn get_db(&self) -> i64

Returns the database this connection is bound to. Note that this information might be unreliable because it’s initially cached and also might be incorrect if the connection like object is not actually connected.

impl Debug for MultiplexedConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.