async_compression/tokio/write/generic/
decoder.rs

1use crate::{generic::write::impl_decoder, tokio::write::BufWriter};
2use std::{
3    io,
4    pin::Pin,
5    task::{Context, Poll},
6};
7use tokio::io::{AsyncBufRead, AsyncRead, AsyncWrite, ReadBuf};
8
9impl_decoder!(poll_shutdown);
10
11impl<W: AsyncRead, D> AsyncRead for Decoder<W, D> {
12    fn poll_read(
13        self: Pin<&mut Self>,
14        cx: &mut Context<'_>,
15        buf: &mut ReadBuf<'_>,
16    ) -> Poll<io::Result<()>> {
17        self.get_pin_mut().poll_read(cx, buf)
18    }
19}