diff --git a/src/lib.rs b/src/lib.rs index fd860cf..790b2a1 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -121,5 +121,6 @@ pub fn par_stream_archive( })?; let mut writer = writer.into_inner().map_err(|_| Error::MutexError)?; writer.write_all(&[0; 8])?; + sender.send(Message::Eof).map_err(|_| Error::SenderError)?; Ok(()) }