Enum redis::aio::async_std::AsyncStd

pub enum AsyncStd {
    Tcp(AsyncStdWrapped<TcpStream>),
    TcpTls(AsyncStdWrapped<TlsStream<TcpStream>>),
    Unix(AsyncStdWrapped<UnixStream>),
}

This is supported on crate features aio and async-std-comp only.

Represents an AsyncStd connectable

Variants

Tcp(AsyncStdWrapped<TcpStream>)

Represents an Async_std TCP connection.

TcpTls(AsyncStdWrapped<TlsStream<TcpStream>>)

Represents an Async_std TLS encrypted TCP connection.

Unix(AsyncStdWrapped<UnixStream>)

Represents an Async_std Unix connection.

Trait Implementations

impl AsyncRead for AsyncStd

fn poll_read(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &mut ReadBuf<'_>
) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for AsyncStd

fn poll_write(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &[u8]
) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

pub fn poll_write_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    bufs: &[IoSlice<'_>]
) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

pub fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.