Struct CopyBuffer

pub struct CopyBuffer<B, SR, SW> { /* private fields */ }

A wrapper of its underlying buffer(array, vector, unix pipe…).

Implementations

impl<B, SR, SW> CopyBuffer<B, SR, SW>

pub const fn new(buf: B) -> Self

Constructor, take the provided buffer.

impl<B, SR, SW> CopyBuffer<B, SR, SW>

where B: Unpin, SR: AsyncRead + AsyncWrite + Unpin, SW: AsyncRead + AsyncWrite + Unpin, CopyBuffer<B, SR, SW>: AsyncIOBuf,

pub fn poll_copy( &mut self, cx: &mut Context<'_>, r: &mut <CopyBuffer<B, SR, SW> as AsyncIOBuf>::StreamR, w: &mut <CopyBuffer<B, SR, SW> as AsyncIOBuf>::StreamW, ) -> Poll<Result<u64>>

Copy data from reader to writer via buffer, asynchronously.

Trait Implementations

impl<'a, SR, SW> AsyncIOBuf for CopyBuffer<&'a mut Pipe, SR, SW>

where SR: AsyncRead + AsyncWrite + AsyncRawIO + Unpin, SW: AsyncRead + AsyncWrite + AsyncRawIO + Unpin,

type StreamR = SR

type StreamW = SW

fn poll_read_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamR, ) -> Poll<Result<usize>>

fn poll_write_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamW, ) -> Poll<Result<usize>>

fn poll_flush_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamW, ) -> Poll<Result<()>>

impl<B, SR, SW> AsyncIOBuf for CopyBuffer<B, SR, SW>

where B: AsMut<[u8]>, SR: AsyncRead + AsyncWrite + Unpin, SW: AsyncRead + AsyncWrite + Unpin,

type StreamR = SR

type StreamW = SW

fn poll_read_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamR, ) -> Poll<Result<usize>>

fn poll_write_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamW, ) -> Poll<Result<usize>>

fn poll_flush_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamW, ) -> Poll<Result<()>>

impl<SR, SW> AsyncIOBuf for CopyBuffer<Pipe, SR, SW>

where SR: AsyncRead + AsyncWrite + AsyncRawIO + Unpin, SW: AsyncRead + AsyncWrite + AsyncRawIO + Unpin,

type StreamR = SR

type StreamW = SW

fn poll_read_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamR, ) -> Poll<Result<usize>>

fn poll_write_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamW, ) -> Poll<Result<usize>>

fn poll_flush_buf( &mut self, cx: &mut Context<'_>, stream: &mut Self::StreamW, ) -> Poll<Result<()>>