From 5c47f500d9d5b7cda25330544bf3414938dff5bc Mon Sep 17 00:00:00 2001 From: Lucas Schumacher Date: Mon, 15 Apr 2024 22:13:06 -0400 Subject: [PATCH] Fix async runtime issue --- src/app.rs | 29 +++++++++-------------------- 1 file changed, 9 insertions(+), 20 deletions(-) diff --git a/src/app.rs b/src/app.rs index b60bf7a..090b4ca 100644 --- a/src/app.rs +++ b/src/app.rs @@ -20,28 +20,20 @@ impl App { let ble_sender = send.clone(); std::thread::spawn(move || term_event_sender(send)); - let async_runtime = tokio::runtime::Builder::new_multi_thread() - .enable_all() - .build() - .unwrap(); - async_runtime.spawn(async move { - let e = ble_event_sender(&ble_sender) - .await - .expect_err("Bluetooth thread closed"); - ble_sender - .send(AppEvent::Log(format!("Unrecoverable Error: {e}"))) - .expect("mpsc fail :("); - }); - /* - std::thread::spawn(move || { + std::thread::spawn(move || { + tokio::runtime::Builder::new_multi_thread() + .enable_all() + .build() + .unwrap() + .block_on(async move { let e = ble_event_sender(&ble_sender) - .block_on() + .await .expect_err("Bluetooth thread closed"); ble_sender - .send(AppEvent::Log(format!("Unrecoverable Error: {}", e))) + .send(AppEvent::Log(format!("Unrecoverable Error: {e}"))) .expect("mpsc fail :("); }); - */ + }); Self { events: recv, @@ -50,9 +42,6 @@ impl App { } } fn ui(&mut self, f: &mut Frame) { - //let greeting = widgets::Paragraph::new("Hello World!"); - //f.render_widget(greeting, f.size()); - let logs: Vec = self .logs .iter()