From 4f59b256f5103c585637709f0f9095839a37bf23 Mon Sep 17 00:00:00 2001 From: Jared Burce Date: Thu, 22 Oct 2020 12:23:08 -0700 Subject: [PATCH] simplify client Vec management --- src/main.rs | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/main.rs b/src/main.rs index 92d8b69..27f288d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -29,8 +29,7 @@ async fn main() { pretty_env_logger::init_timed(); let clients = Arc::new(Mutex::new(SmallVec::new())); - let clients_filter = clients.clone(); - let clients_filter = warp::any().map(move || clients_filter.clone()); + let events_clients = clients.clone(); let gpio = Gpio::new().expect("gpio init"); let mut pin = gpio.get(BUTTON_PIN).expect("pin init").into_input_pullup(); @@ -47,11 +46,10 @@ async fn main() { // GET /events let events = warp::path!("events") .and(warp::get()) - .and(clients_filter) - .map(|clients: Arc>>| { + .map(move || { info!("GET /events"); let (tx, rx) = mpsc::channel(1); - clients.lock().unwrap().push(tx); + events_clients.lock().unwrap().push(tx); let stream = stream::select( interval(Duration::from_secs(5)).map(move |_| {