Struct redis::aio::Connection

pub struct Connection<C = Pin<Box<dyn AsyncStream + Send + Sync>>> { /* private fields */ }

Available on crate feature aio only.

Represents a stateful redis TCP connection.

Implementations

impl<C> Connection<C>where
    C: Unpin + AsyncRead + AsyncWrite + Send,

pub async fn new(
    connection_info: &RedisConnectionInfo,
    con: C
) -> RedisResult<Self>

Constructs a new Connection out of a AsyncRead + AsyncWrite object and a RedisConnectionInfo

pub fn into_pubsub(self) -> PubSub<C>

Converts this Connection into PubSub.

pub fn into_monitor(self) -> Monitor<C>

Converts this Connection into Monitor

impl<C> Connection<AsyncStdWrapped<C>>where
    C: Unpin + Read + Write + Send,

pub async fn new_async_std(
    connection_info: &RedisConnectionInfo,
    con: C
) -> RedisResult<Self>

Available on crate feature async-std-comp only.

Constructs a new Connection out of a async_std::io::AsyncRead + async_std::io::AsyncWrite object and a RedisConnectionInfo

Trait Implementations

impl<C> ConnectionLike for Connection<C>where
    C: Unpin + AsyncRead + AsyncWrite + Send,

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.