Struct Duplex 

pub struct Duplex<R, W> { /* private fields */ }

Combine a reader + writer into a duplex of Read + Write.

Implementations

impl<R, W> Duplex<R, W>

pub fn new(reader: R, writer: W) -> Self

Create a new instance.

Examples found in repository

examples/stdio.rs (line 9)

fn main() -> std::io::Result<()> {
    task::block_on(async {
        let stdin = BufReader::new(io::stdin());
        let stdout = io::stdout();
        let mut stdio = Duplex::new(stdin, stdout);

        let mut line = String::new();
        stdio.read_line(&mut line).await?;
        stdio.write_all(&line.as_bytes()).await?;

        Ok(())
    })
}

pub fn into_inner(self) -> (R, W)

Decomposes a duplex into its components.

Trait Implementations

impl<R: BufRead, W> AsyncBufRead for Duplex<R, W>

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

Attempt to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

impl<R, W> Clone for Duplex<R, W>

where R: Clone, W: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R: Debug, W: Debug> Debug for Duplex<R, W>

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

Formats the value using the given formatter.

impl<R: Read, W> AsyncRead for Duplex<R, W>

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

Attempt to read from the AsyncRead into buf.

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

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<R, W: Write> AsyncWrite for Duplex<R, W>

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<()>>

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

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

Attempt to close the object.

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

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<'__pin, R, W> Unpin for Duplex<R, W>

where __Origin<'__pin, R, W>: Unpin,