From 2c3950ccfc4f792ff83658238ed2084788ea0c1d Mon Sep 17 00:00:00 2001
From: Dmitry <b4tm4n@mail.ru>
Date: Tue, 8 Aug 2023 16:50:02 +0300
Subject: [PATCH] fix write_db tokio join
---
app_async/src/main.rs | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/app_async/src/main.rs b/app_async/src/main.rs
index a3caa1d..e39c9c2 100644
--- a/app_async/src/main.rs
+++ b/app_async/src/main.rs
@@ -170,8 +170,10 @@ async fn read_from_db(id: u32) -> Option<Question> {
}
async fn write_db() {
let (tx, rx) = mpsc::unbounded_channel::<Question>();
- let (r, _) = tokio::join!(tokio::spawn(zip_reader_task(tx)), db_writer_task(rx),);
- r.expect("tokio join");
+ tokio::try_join!(
+ tokio::spawn(zip_reader_task(tx)),
+ tokio::spawn(db_writer_task(rx))
+ ).expect("tokio join");
println!("all done");
}
async fn db_writer_task(rx: UnboundedReceiver<Question>) {