Function process_events_async_with_kv_store_sync 

pub async fn process_events_async_with_kv_store_sync<UL: Deref, CF: Deref, T: Deref, F: Deref, G: Deref<Target = NetworkGraph<L>>, L: Deref + Send + Sync, P: Deref, EventHandlerFuture: Future<Output = Result<(), ReplayEvent>>, EventHandler: Fn(Event) -> EventHandlerFuture, ES: Deref + Send, M: Deref<Target = ChainMonitor<<CM::Target as AChannelManager>::Signer, CF, T, F, L, P, ES>> + Send + Sync, CM: Deref + Send + Sync, OM: Deref, PGS: Deref<Target = P2PGossipSync<G, UL, L>>, RGS: Deref<Target = RapidGossipSync<G, L>>, PM: Deref, LM: Deref, D: Deref, O: Deref, K: Deref, OS: Deref<Target = OutputSweeperSync<T, D, F, CF, K, L, O>>, S: Deref<Target = SC> + Send + Sync, SC: for<'b> WriteableScore<'b>, SleepFuture: Future<Output = bool> + Unpin, Sleeper: Fn(Duration) -> SleepFuture, FetchTime: Fn() -> Option<Duration>>(
    kv_store: K,
    event_handler: EventHandler,
    chain_monitor: M,
    channel_manager: CM,
    onion_messenger: Option<OM>,
    gossip_sync: GossipSync<PGS, RGS, G, UL, L>,
    peer_manager: PM,
    liquidity_manager: Option<LM>,
    sweeper: Option<OS>,
    logger: L,
    scorer: Option<S>,
    sleeper: Sleeper,
    mobile_interruptable_platform: bool,
    fetch_time: FetchTime,
) -> Result<(), Error>
where
    UL::Target: UtxoLookup,
    CF::Target: Filter,
    T::Target: BroadcasterInterface,
    F::Target: FeeEstimator,
    L::Target: Logger,
    P::Target: Persist<<CM::Target as AChannelManager>::Signer>,
    ES::Target: EntropySource,
    CM::Target: AChannelManager,
    OM::Target: AOnionMessenger,
    PM::Target: APeerManager,
    LM::Target: ALiquidityManager,
    O::Target: OutputSpender,
    D::Target: ChangeDestinationSourceSync,
    K::Target: KVStoreSync,

Async events processor that is based on process_events_async but allows for KVStoreSync to be used for synchronous background persistence.