app_async: don't use writer.sink()

2023-08-15 10:44:32 +03:00
parent 07d7ba50cc
commit 0adc11cabf
1 changed files with 2 additions and 2 deletions
--- a/app_async/src/main.rs
+++ b/app_async/src/main.rs
@@ -181,8 +181,8 @@ async fn db_writer_task(rx: UnboundedReceiver<Question>) {
            .unwrap_or_else(|e| panic!("db writer load, {e:#?}"));

    let stream: UnboundedReceiverStream<_> = rx.into();
-    let stream = stream.map(Ok);
-    stream.forward(writer.sink()).await.expect("forward");
+    let stream = stream;
+    writer.load(stream).await.expect("load");
    writer.finish().await.expect("db writer finish");

    println!("write done");