Struct redis::aio::MultiplexedConnection [−][src]
pub struct MultiplexedConnection { /* fields omitted */ }
This is supported on crate feature
aio
only.Expand description
A connection object which can be cloned, allowing requests to be be sent concurrently on the same underlying connection (tcp/unix socket).
Implementations
pub async fn new<C>(
connection_info: &RedisConnectionInfo,
stream: C
) -> RedisResult<(Self, impl Future<Output = ()>)> where
C: Unpin + AsyncRead + AsyncWrite + Send + 'static,
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
Trait Implementations
Sends an already encoded (packed) command into the TCP socket and reads the single response from it. Read more
fn req_packed_commands<'a>(
&'a mut self,
cmd: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>
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. Read more
Auto Trait Implementations
impl !RefUnwindSafe for MultiplexedConnection
impl Send for MultiplexedConnection
impl Sync for MultiplexedConnection
impl Unpin for MultiplexedConnection
impl !UnwindSafe for MultiplexedConnection
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V