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