From 576188da123fbf6ec4af6f5dc01492f8c377af9d Mon Sep 17 00:00:00 2001 From: Pierre Hubert Date: Wed, 7 Dec 2022 11:16:42 +0100 Subject: [PATCH] Fix potential memory leak --- src/main.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main.rs b/src/main.rs index 879eeb8..a3435d6 100644 --- a/src/main.rs +++ b/src/main.rs @@ -97,7 +97,7 @@ async fn index() -> HttpResponse { ) } -struct SendWrapper(mpsc::Sender>); +struct SendWrapper(mpsc::SyncSender>); impl Write for SendWrapper { fn write(&mut self, buf: &[u8]) -> std::io::Result { @@ -122,7 +122,7 @@ struct FileStreamer { impl FileStreamer { pub fn start() -> Self { - let (send, receive) = mpsc::channel(); + let (send, receive) = mpsc::sync_channel(1); std::thread::spawn(move || { let mut tar = tar::Builder::new(SendWrapper(send));