Function run_persist_subscriber 

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