[−][src]Struct futures_test::io::read::Limited

pub struct Limited<Io> { /* fields omitted */ }

I/O wrapper that limits the number of bytes written or read on each call.

See the limited and limited_write methods.

Methods

impl<Io> Limited<Io>[src]

pub fn get_ref(&self) -> &Io[src]

Acquires a reference to the underlying I/O object that this adaptor is wrapping.

pub fn get_mut(&mut self) -> &mut Io[src]

Acquires a mutable reference to the underlying I/O object that this adaptor is wrapping.

pub fn get_pin_mut<'a>(self: Pin<&'a mut Self>) -> Pin<&'a mut Io>[src]

Acquires a pinned mutable reference to the underlying I/O object that this adaptor is wrapping.

pub fn into_inner(self) -> Io[src]

Consumes this adaptor returning the underlying I/O object.

Trait Implementations

impl<Io: Unpin> Unpin for Limited<Io>[src]

impl<Io: Debug> Debug for Limited<Io>[src]

impl<R: AsyncRead> AsyncRead for Limited<R>[src]

unsafe fn initializer(&self) -> Initializer[src]

Determines if this AsyncReader can work with buffers of uninitialized memory. Read more

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

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

impl<W: AsyncWrite> AsyncWrite for Limited<W>[src]

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

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

impl<R: AsyncBufRead> AsyncBufRead for Limited<R>[src]

Auto Trait Implementations

impl<Io> Send for Limited<Io> where
    Io: Send, 

impl<Io> Sync for Limited<Io> where
    Io: Sync, 

impl<Io> UnwindSafe for Limited<Io> where
    Io: UnwindSafe, 

impl<Io> RefUnwindSafe for Limited<Io> where
    Io: RefUnwindSafe, 

Blanket Implementations

impl<R> AsyncReadTestExt for R where
    R: AsyncRead, [src]

ⓘImportant traits for InterleavePending<Fut>
fn interleave_pending(self) -> InterleavePending<Self> where
    Self: Sized, [src]

Introduces an extra Poll::Pending in between each read of the reader. Read more

fn limited(self, limit: usize) -> Limited<Self> where
    Self: Sized, [src]

Limit the number of bytes allowed to be read on each call to poll_read. Read more

impl<W> AsyncWriteTestExt for W where
    W: AsyncWrite, [src]

ⓘImportant traits for InterleavePending<Fut>
fn interleave_pending_write(self) -> InterleavePending<Self> where
    Self: Sized, [src]

Introduces an extra Poll::Pending in between each operation on the writer. Read more

fn limited_write(self, limit: usize) -> Limited<Self> where
    Self: Sized, [src]

Limit the number of bytes allowed to be written on each call to poll_write. Read more

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<R> AsyncReadExt for R where
    R: AsyncRead + ?Sized, [src]

fn copy_into<W>(self, writer: &mut W) -> CopyInto<Self, W> where
    W: AsyncWrite + Unpin + ?Sized, [src]

Creates a future which copies all the bytes from one object to another. Read more

fn read(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self> where
    Self: Unpin, [src]

Tries to read some bytes directly into the given buf in asynchronous manner, returning a future type. Read more

fn read_vectored(
    &'a mut self,
    bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
    Self: Unpin, [src]

Creates a future which will read from the AsyncRead into bufs using vectored IO operations. Read more

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self> where
    Self: Unpin, [src]

Creates a future which will read exactly enough bytes to fill buf, returning an error if end of file (EOF) is hit sooner. Read more

fn read_to_end(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEnd<'a, Self> where
    Self: Unpin, [src]

Creates a future which will read all the bytes from this AsyncRead. Read more

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
    Self: AsyncWrite, [src]

Helper method for splitting this read/write object into two halves. Read more

fn compat(self) -> Compat<Self> where
    Self: Unpin, [src]

Wraps an [AsyncRead] in a compatibility wrapper that allows it to be used as a futures 0.1 / tokio-io 0.1 AsyncRead. If the wrapped type implements [AsyncWrite] as well, the result will also implement the futures 0.1 / tokio 0.1 AsyncWrite trait. Read more

impl<W> AsyncWriteExt for W where
    W: AsyncWrite + ?Sized, [src]

fn flush(&mut self) -> Flush<Self> where
    Self: Unpin, [src]

Creates a future which will entirely flush this AsyncWrite. Read more

fn close(&mut self) -> Close<Self> where
    Self: Unpin, [src]

Creates a future which will entirely close this AsyncWrite.

fn write(&'a mut self, buf: &'a [u8]) -> Write<'a, Self> where
    Self: Unpin, [src]

Creates a future which will write bytes from buf into the object. Read more

fn write_vectored(
    &'a mut self,
    bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
    Self: Unpin, [src]

Creates a future which will write bytes from bufs into the object using vectored IO operations. Read more

fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAll<'a, Self> where
    Self: Unpin, [src]

Write data into this object. Read more

fn compat_write(self) -> Compat<Self> where
    Self: Unpin, [src]

Wraps an [AsyncWrite] in a compatibility wrapper that allows it to be used as a futures 0.1 / tokio-io 0.1 AsyncWrite. Requires the io-compat feature to enable. Read more

fn into_sink<Item>(self) -> IntoSink<Self, Item> where
    Item: AsRef<[u8]>, [src]

Allow using an [AsyncWrite] as a Sink``<Item: AsRef<[u8]>>. Read more

impl<R> AsyncBufReadExt for R where
    R: AsyncBufRead + ?Sized, [src]

fn copy_buf_into<W>(self, writer: &mut W) -> CopyBufInto<Self, W> where
    W: AsyncWrite + Unpin + ?Sized, [src]

Creates a future which copies all the bytes from one object to another. Read more

fn read_until(
    &'a mut self,
    byte: u8,
    buf: &'a mut Vec<u8>
) -> ReadUntil<'a, Self> where
    Self: Unpin, [src]

Creates a future which will read all the bytes associated with this I/O object into buf until the delimiter byte or EOF is reached. This method is the async equivalent to BufRead::read_until. Read more

fn read_line(&'a mut self, buf: &'a mut String) -> ReadLine<'a, Self> where
    Self: Unpin, [src]

Creates a future which will read all the bytes associated with this I/O object into buf until a newline (the 0xA byte) or EOF is reached, This method is the async equivalent to BufRead::read_line. Read more

fn lines(self) -> Lines<Self>[src]

Returns a stream over the lines of this reader. This method is the async equivalent to BufRead::lines. Read more

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,