youwen5/jankboard
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: refactor telemetry to use new method

Browse source
This commit is contained in:
Youwen Wu 2024-03-07 12:31:18 -08:00
parent fc39e9e740
commit b0d075bbfd
Signed by: youwen5
GPG key ID: 865658ED1FE61EC3
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
client/src-tauri/src/telemetry/mod.rs
View file

@ -1,4 +1,4 @@
use network_tables::v4::MessageData; use network_tables::v4::{MessageData, Subscription};
use serde_json::to_string; use serde_json::to_string;
use tauri::{AppHandle, Manager}; use tauri::{AppHandle, Manager};
mod create_client; mod create_client;
@ -23,7 +23,15 @@ pub async fn subscribe_topics(
// I hope this doesn't lead to a catastrophic infinite loop failure // I hope this doesn't lead to a catastrophic infinite loop failure
let client = create_client(&app_handle, &ntable_ip, &ntable_port).await; let client = create_client(&app_handle, &ntable_ip, &ntable_port).await;
let mut subscription = create_subscription(&client).await; let mut subscription: Subscription = match create_subscription(&client).await {
Ok(subscription) => subscription,
Err(_) => {
app_handle
.emit_all("telemetry_status", "disconnected")
.expect("Failed to emit telemetry_disconnected event");
continue;
}
};
while let Some(mut message) = subscription.next().await { while let Some(mut message) = subscription.next().await {
process_message(&mut message); process_message(&mut message);