flush

Cargo.lock

@@ -605,7 +605,7 @@ dependencies = [
 
 [[package]]
 name = "markov"
-version = "0.2.0"
+version = "0.3.0"
 dependencies = [
  "cfg-if 1.0.0",
  "futures",

src/save.rs

@@ -55,6 +55,7 @@ async fn save_now_to(chain: &Chain<String>, to: impl AsRef<Path>) -> io::Result<
     let mut file = AsyncWriteCompressor::new(file, PreferencesBuilder::new()
 					     .compression_level(lz4f::CLEVEL_HIGH).build())?;
     file.write_all(&chain[..]).await?;
+    file.flush().await?;
     file.shutdown().await?;
     Ok(())
 }