We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c60191a commit 171f98cCopy full SHA for 171f98c
src/common/arrow/src/arrow/io/ipc/compression.rs
@@ -13,13 +13,15 @@
13
// See the License for the specific language governing permissions and
14
// limitations under the License.
15
16
+use std::io::Read;
17
+
18
use crate::arrow::error::Result;
19
20
#[cfg(feature = "io_ipc_compression")]
21
#[cfg_attr(docsrs, doc(cfg(feature = "io_ipc_compression")))]
22
pub fn decompress_lz4(input_buf: &[u8], output_buf: &mut [u8]) -> Result<()> {
23
use std::io::Read;
- let _ = lz4_flex::frame::FrameDecoder::new(input_buf).read(output_buf)?;
24
+ lz4_flex::frame::FrameDecoder::new(input_buf).read_exact(output_buf)?;
25
Ok(())
26
}
27
0 commit comments