vector_common/
compression.rs1use async_compression::tokio::bufread::GzipDecoder;
2use tokio::io::AsyncBufRead;
3
4#[allow(clippy::disallowed_methods)]
5pub fn gzip_multiple_decoder<R: AsyncBufRead>(reader: R) -> GzipDecoder<R> {
6 let mut decoder = GzipDecoder::new(reader);
7 decoder.multiple_members(true);
8 decoder
9}