From 314ae43a45d09bfe71257a14cf2b1c3a76de364f Mon Sep 17 00:00:00 2001 From: Pascal Seitz Date: Thu, 2 Jun 2022 14:54:23 +0800 Subject: [PATCH] fix fmt --- src/store/reader.rs | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/src/store/reader.rs b/src/store/reader.rs index a0d4654c2..3cb4f038d 100644 --- a/src/store/reader.rs +++ b/src/store/reader.rs @@ -140,9 +140,11 @@ impl StoreReader { } let compressed_block = self.get_compressed_block(checkpoint)?; - let decompressed_block = OwnedBytes::new(self.compressor.decompress(compressed_block.as_ref())?); + let decompressed_block = + OwnedBytes::new(self.compressor.decompress(compressed_block.as_ref())?); - self.cache.put_into_cache(cache_key, decompressed_block.clone()); + self.cache + .put_into_cache(cache_key, decompressed_block.clone()); Ok(decompressed_block) } @@ -318,9 +320,11 @@ impl StoreReader { .read_bytes_async() .await?; - let decompressed_block = OwnedBytes::new(self.compressor.decompress(compressed_block.as_ref())?); + let decompressed_block = + OwnedBytes::new(self.compressor.decompress(compressed_block.as_ref())?); - self.cache.put_into_cache(cache_key, decompressed_block.clone()); + self.cache + .put_into_cache(cache_key, decompressed_block.clone()); Ok(decompressed_block) }