Struct compio_io::util::Repeat

pub struct Repeat(/* private fields */);

A reader that infinitely repeats one byte constructed via repeat.

All reads from this reader will succeed by filling the specified buffer with the given byte.

Examples

use compio_io::{self, AsyncRead, AsyncReadExt};

let (len, buffer) = compio_io::repeat(42)
    .read(Vec::with_capacity(3))
    .await
    .unwrap();

assert_eq!(buffer.as_slice(), [42, 42, 42]);
assert_eq!(len, 3);

Trait Implementations

impl AsyncBufRead for Repeat

async fn fill_buf(&mut self) -> Result<&[u8]>

Try fill the internal buffer with data

fn consume(&mut self, _: usize)

Mark how much data is read

impl AsyncRead for Repeat

async fn read<B: IoBufMut>(&mut self, buf: B) -> BufResult<usize, B>

Read some bytes from this source into the IoBufMut buffer and return a BufResult, consisting of the buffer and a usize indicating how many bytes were read.

async fn read_vectored<V: IoVectoredBufMut>( &mut self, buf: V, ) -> BufResult<usize, V>

Like read, except that it reads into a type implements IoVectoredBufMut.