async-compression 0.4.41

Adaptors between compression crates and Rust's modern asynchronous IO types.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

mod copy_buf;
mod interleave_pending;
mod limited;

pub use copy_buf::copy_buf;

pub trait AsyncWriteTestExt: tokio::io::AsyncWrite {
    fn interleave_pending_write(self) -> interleave_pending::InterleavePending<Self>
    where
        Self: Sized + Unpin,
    {
        interleave_pending::InterleavePending::new(self)
    }

    fn limited_write(self, limit: usize) -> limited::Limited<Self>
    where
        Self: Sized + Unpin,
    {
        limited::Limited::new(self, limit)
    }
}

impl<T: tokio::io::AsyncWrite> AsyncWriteTestExt for T {}