pub fn setup_persistence_req_sender() -> Result<(PersistenceReqSender, impl Future<Output = ()>), Error>