lks/bleeper
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix async runtime issue

Browse Source
This commit is contained in:
Lucas Schumacher 2024-04-15 22:13:06 -04:00
parent 710522ba3d
commit 5c47f500d9
1 changed files with 9 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/app.rs
View File

@ -20,11 +20,12 @@ impl App {
let ble_sender = send.clone(); let ble_sender = send.clone();
std::thread::spawn(move || term_event_sender(send)); std::thread::spawn(move || term_event_sender(send));
let async_runtime = tokio::runtime::Builder::new_multi_thread() std::thread::spawn(move || {
tokio::runtime::Builder::new_multi_thread()
.enable_all() .enable_all()
.build() .build()
.unwrap(); .unwrap()
async_runtime.spawn(async move { .block_on(async move {
let e = ble_event_sender(&ble_sender) let e = ble_event_sender(&ble_sender)
.await .await
.expect_err("Bluetooth thread closed"); .expect_err("Bluetooth thread closed");
@ -32,16 +33,7 @@ impl App {
.send(AppEvent::Log(format!("Unrecoverable Error: {e}"))) .send(AppEvent::Log(format!("Unrecoverable Error: {e}")))
.expect("mpsc fail :("); .expect("mpsc fail :(");
}); });
/*
std::thread::spawn(move || {
let e = ble_event_sender(&ble_sender)
.block_on()
.expect_err("Bluetooth thread closed");
ble_sender
.send(AppEvent::Log(format!("Unrecoverable Error: {}", e)))
.expect("mpsc fail :(");
}); });
*/
Self { Self {
events: recv, events: recv,
@ -50,9 +42,6 @@ impl App {
} }
} }
fn ui(&mut self, f: &mut Frame) { fn ui(&mut self, f: &mut Frame) {
//let greeting = widgets::Paragraph::new("Hello World!");
//f.render_widget(greeting, f.size());
let logs: Vec<ListItem> = self let logs: Vec<ListItem> = self
.logs .logs
.iter() .iter()