From 0d1bbc8eb527e727f6cb322b9ecfc7004031e1ef Mon Sep 17 00:00:00 2001 From: Philipp Oppermann Date: Wed, 8 Feb 2023 12:26:54 +0100 Subject: [PATCH] Fix: actually send input to runtime instead of dropping future --- binaries/runtime/src/lib.rs | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/binaries/runtime/src/lib.rs b/binaries/runtime/src/lib.rs index 9b4c1f49..f1336648 100644 --- a/binaries/runtime/src/lib.rs +++ b/binaries/runtime/src/lib.rs @@ -199,11 +199,13 @@ async fn run( continue; }; - let _ = operator_channel.send(operator::IncomingEvent::Input { - input_id, - metadata, - data, - }); + operator_channel + .send(operator::IncomingEvent::Input { + input_id, + metadata, + data, + }) + .await?; } Event::InputClosed(_) => {} Event::Error(err) => eyre::bail!("received error event: {err}"),