diff --git a/app_async/src/main.rs b/app_async/src/main.rs
index 9049829..1c705f3 100644
--- 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");