@@ -1187,80 +1187,6 @@ fn check_and_reset_sleeper<
11871187 }
11881188}
11891189
1190- /// Async events processor that is based on [`process_events_async`] but allows for [`KVStoreSync`] to be used for
1191- /// synchronous background persistence.
1192- pub async fn process_events_async_with_kv_store_sync <
1193- UL : ' static + Deref ,
1194- CF : ' static + Deref ,
1195- T : ' static + Deref ,
1196- F : ' static + Deref ,
1197- G : ' static + Deref < Target = NetworkGraph < L > > ,
1198- L : ' static + Deref + Send + Sync ,
1199- P : ' static + Deref ,
1200- EventHandlerFuture : core:: future:: Future < Output = Result < ( ) , ReplayEvent > > ,
1201- EventHandler : Fn ( Event ) -> EventHandlerFuture ,
1202- ES : ' static + Deref + Send ,
1203- M : ' static
1204- + Deref < Target = ChainMonitor < <CM :: Target as AChannelManager >:: Signer , CF , T , F , L , P , ES > >
1205- + Send
1206- + Sync ,
1207- CM : ' static + Deref + Send + Sync ,
1208- OM : ' static + Deref ,
1209- PGS : ' static + Deref < Target = P2PGossipSync < G , UL , L > > ,
1210- RGS : ' static + Deref < Target = RapidGossipSync < G , L > > ,
1211- PM : ' static + Deref ,
1212- LM : ' static + Deref ,
1213- D : ' static + Deref ,
1214- O : ' static + Deref ,
1215- K : ' static + Deref ,
1216- OS : ' static + Deref < Target = OutputSweeper < T , D , F , CF , KVStoreSyncWrapper < K > , L , O > > ,
1217- S : ' static + Deref < Target = SC > + Send + Sync ,
1218- SC : for < ' b > WriteableScore < ' b > ,
1219- SleepFuture : core:: future:: Future < Output = bool > + core:: marker:: Unpin ,
1220- Sleeper : Fn ( Duration ) -> SleepFuture ,
1221- FetchTime : Fn ( ) -> Option < Duration > ,
1222- > (
1223- kv_store : K , event_handler : EventHandler , chain_monitor : M , channel_manager : CM ,
1224- onion_messenger : Option < OM > , gossip_sync : GossipSync < PGS , RGS , G , UL , L > , peer_manager : PM ,
1225- liquidity_manager : Option < LM > , sweeper : Option < OS > , logger : L , scorer : Option < S > ,
1226- sleeper : Sleeper , mobile_interruptable_platform : bool , fetch_time : FetchTime ,
1227- ) -> Result < ( ) , lightning:: io:: Error >
1228- where
1229- UL :: Target : ' static + UtxoLookup ,
1230- CF :: Target : ' static + chain:: Filter ,
1231- T :: Target : ' static + BroadcasterInterface ,
1232- F :: Target : ' static + FeeEstimator ,
1233- L :: Target : ' static + Logger ,
1234- P :: Target : ' static + Persist < <CM :: Target as AChannelManager >:: Signer > ,
1235- ES :: Target : ' static + EntropySource ,
1236- CM :: Target : AChannelManager ,
1237- OM :: Target : AOnionMessenger ,
1238- PM :: Target : APeerManager ,
1239- LM :: Target : ALiquidityManager ,
1240- O :: Target : ' static + OutputSpender ,
1241- D :: Target : ' static + ChangeDestinationSource ,
1242- K :: Target : ' static + KVStoreSync ,
1243- {
1244- let kv_store = KVStoreSyncWrapper ( kv_store) ;
1245- process_events_async (
1246- kv_store,
1247- event_handler,
1248- chain_monitor,
1249- channel_manager,
1250- onion_messenger,
1251- gossip_sync,
1252- peer_manager,
1253- liquidity_manager,
1254- sweeper,
1255- logger,
1256- scorer,
1257- sleeper,
1258- mobile_interruptable_platform,
1259- fetch_time,
1260- )
1261- . await
1262- }
1263-
12641190#[ cfg( feature = "std" ) ]
12651191impl BackgroundProcessor {
12661192 /// Start a background thread that takes care of responsibilities enumerated in the [top-level
0 commit comments