diff --git a/src/app.rs b/src/app.rs index 94f0605..a4b9029 100644 --- a/src/app.rs +++ b/src/app.rs @@ -29,6 +29,11 @@ impl App { tx } + pub fn clear(&self) { + let mut state = self.state.write().unwrap(); + *state = None; + } + // TODO: async drop til 1st header pub fn subscribe(&self) -> Option> { let state = self.state.read().unwrap(); diff --git a/src/client.rs b/src/client.rs index a72bc05..382098d 100644 --- a/src/client.rs +++ b/src/client.rs @@ -57,6 +57,7 @@ pub async fn run(app: App) { loop { run_once(&app).await .unwrap_or_else(|e| println!("Client: {:?}", e)); + app.clear(); sleep(Duration::from_secs(1)).await; }