diff --git a/libraries/extensions/dora-record/src/main.rs b/libraries/extensions/dora-record/src/main.rs index 17ff83453..fb10bf18e 100644 --- a/libraries/extensions/dora-record/src/main.rs +++ b/libraries/extensions/dora-record/src/main.rs @@ -85,6 +85,9 @@ async fn main() -> eyre::Result<()> { } writer.close().await }); + tx.send((data.into(), metadata)) + .await + .context("Could not send event data into writer loop")?; writers.insert(id, (tx, join_handle)); } Some((tx, _)) => {