diff --git a/crates/async-compression/src/futures/bufread/generic/decoder.rs b/crates/async-compression/src/futures/bufread/generic/decoder.rs index 802eaa5..6b91142 100644 --- a/crates/async-compression/src/futures/bufread/generic/decoder.rs +++ b/crates/async-compression/src/futures/bufread/generic/decoder.rs @@ -1,4 +1,4 @@ -use crate::{codecs::Decode, core::util::PartialBuffer, generic::bufread::impl_do_poll_read}; +use crate::{codecs::Decode, core::util::PartialBuffer, generic::bufread::impl_decoder}; use core::{ pin::Pin, @@ -8,7 +8,7 @@ use std::io::{IoSlice, Result}; use futures_io::{AsyncBufRead, AsyncRead, AsyncWrite}; -impl_do_poll_read!(); +impl_decoder!(); impl AsyncRead for Decoder { fn poll_read( diff --git a/crates/async-compression/src/generic/bufread/decoder.rs b/crates/async-compression/src/generic/bufread/decoder.rs index be45625..41b9410 100644 --- a/crates/async-compression/src/generic/bufread/decoder.rs +++ b/crates/async-compression/src/generic/bufread/decoder.rs @@ -108,7 +108,7 @@ impl Decoder { } } -macro_rules! impl_do_poll_read { +macro_rules! impl_decoder { () => { use crate::generic::bufread::Decoder as GenericDecoder; @@ -195,4 +195,4 @@ macro_rules! impl_do_poll_read { } }; } -pub(crate) use impl_do_poll_read; +pub(crate) use impl_decoder; diff --git a/crates/async-compression/src/tokio/bufread/generic/decoder.rs b/crates/async-compression/src/tokio/bufread/generic/decoder.rs index 1a00792..d5e6406 100644 --- a/crates/async-compression/src/tokio/bufread/generic/decoder.rs +++ b/crates/async-compression/src/tokio/bufread/generic/decoder.rs @@ -1,4 +1,4 @@ -use crate::{codecs::Decode, core::util::PartialBuffer, generic::bufread::impl_do_poll_read}; +use crate::{codecs::Decode, core::util::PartialBuffer, generic::bufread::impl_decoder}; use core::{ pin::Pin, @@ -8,7 +8,7 @@ use std::io::{IoSlice, Result}; use tokio::io::{AsyncBufRead, AsyncRead, AsyncWrite, ReadBuf}; -impl_do_poll_read!(); +impl_decoder!(); impl AsyncRead for Decoder { fn poll_read(