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));