karmaio 0.1.0

A modern, fast, share-nothing asynchronous runtime for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use crate::io::AsyncRead;

/// An asynchronous reader with buffered-content access.
///
/// Futures are `!Send` by design in this share-nothing runtime.
#[allow(async_fn_in_trait)]
pub trait AsyncBufRead: AsyncRead {
    /// Fills the internal buffer, or returns its existing contents.
    async fn fill_buf(&mut self) -> std::io::Result<&'_ [u8]>;

    /// Advances the read position inside the internal buffer.
    fn consume(&mut self, amount: usize);

    /// Returns the current contents of the internal buffer synchronously.
    fn buffer(&self) -> &[u8];
}

impl<T: AsyncBufRead + ?Sized> AsyncBufRead for &mut T {
    async fn fill_buf(&mut self) -> std::io::Result<&'_ [u8]> {
        (**self).fill_buf().await
    }

    fn consume(&mut self, amount: usize) {
        (**self).consume(amount)
    }

    fn buffer(&self) -> &[u8] {
        (**self).buffer()
    }
}