async fn run_persist_subscriber( events_rx: Receiver<Event>, wstore: Arc<Store>, state: Arc<Mutex<State>>, )