Skip to content

Commit 5efb42b

Browse files
committed
fixup: Decoder should be used instead of Encoder in read.rs
1 parent 0a44f6a commit 5efb42b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

bottomless/src/read.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use crate::replicator::CompressionKind;
22
use crate::wal::WalFrameHeader;
33
use anyhow::Result;
4-
use async_compression::tokio::bufread::{GzipDecoder, XzEncoder};
4+
use async_compression::tokio::bufread::{GzipDecoder, XzDecoder};
55
use aws_sdk_s3::primitives::ByteStream;
66
use std::io::ErrorKind;
77
use std::pin::Pin;
@@ -33,7 +33,7 @@ impl BatchReader {
3333
Box::pin(gzip)
3434
}
3535
CompressionKind::Xz => {
36-
let xz = XzEncoder::new(reader);
36+
let xz = XzDecoder::new(reader);
3737
Box::pin(xz)
3838
}
3939
},

0 commit comments

Comments
 (0)