Struct dia_files::Limit

pub struct Limit<R> { /* private fields */ }

Limit

This struct can be used for limiting data read from some source.

Implementations

impl<R> Limit<R>

pub fn new(inner: R, limit: u64) -> Self

Makes new object

impl<R> Limit<R>

where R: Unpin + Read,

pub async fn read_to_end(&mut self, capacity: Option<usize>) -> Result<Vec<u8>>

Available on crate feature async-std only.

Reads all bytes

Be careful using this function (in case your source produces a lot of data).

pub async fn read( stream: R, limit: u64, capacity: Option<usize> ) -> Result<Vec<u8>>

Available on crate feature async-std only.

Reads a whole stream

pub async fn read_to_string( stream: R, limit: u64, capacity: Option<usize> ) -> Result<String>

Available on crate feature async-std only.

Reads a whole stream, then converts data into string

impl Limit<BufReader<File>>

pub async fn open_file<P>(path: P, limit: u64) -> Result<Self>

where P: AsRef<Path>,

Available on crate feature async-std only.

Opens a file for reading with a limit

The file will be wrapped inside a BufReader.

pub async fn read_file<P>(path: P, limit: u64) -> Result<Vec<u8>>

where P: AsRef<Path>,

Available on crate feature async-std only.

Reads a whole file

pub async fn read_file_to_string<P>(path: P, limit: u64) -> Result<String>

where P: AsRef<Path>,

Available on crate feature async-std only.

Reads a whole file to a string

impl Limit<Stdin>

pub fn stdin(limit: u64) -> Self

Makes new object from standard input

impl Limit<StdinLock<'_>>

pub fn lock_stdin(limit: u64) -> Self

Locks standard input and makes new object from it

Trait Implementations

impl<R: Debug> Debug for Limit<R>

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

Formats the value using the given formatter.

impl<R> AsyncRead for Limit<R>

where R: Unpin + Read,

Available on crate feature async-std only.

fn poll_read( self: Pin<&mut Self>, context: &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.