Skip to content

Commit 21dc34c

Browse files
committed
Use async kv store with OutputSweeper
1 parent 90d9a18 commit 21dc34c

File tree

2 files changed

+144
-105
lines changed

2 files changed

+144
-105
lines changed

lightning-background-processor/src/lib.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ use lightning::sign::ChangeDestinationSourceSync;
4040
use lightning::sign::EntropySource;
4141
use lightning::sign::OutputSpender;
4242
use lightning::util::logger::Logger;
43-
use lightning::util::persist::{KVStoreSync, Persister, PersisterSync};
43+
use lightning::util::persist::{KVStore, KVStoreSync, Persister, PersisterSync};
4444
use lightning::util::sweep::OutputSweeper;
4545
#[cfg(feature = "std")]
4646
use lightning::util::sweep::OutputSweeperSync;
@@ -694,7 +694,7 @@ use futures_util::{dummy_waker, OptionalSelector, Selector, SelectorOutput};
694694
/// # type LiquidityManager<B, F, FE> = lightning_liquidity::LiquidityManager<Arc<lightning::sign::KeysManager>, Arc<ChannelManager<B, F, FE>>, Arc<F>>;
695695
/// # type Scorer = RwLock<lightning::routing::scoring::ProbabilisticScorer<Arc<NetworkGraph>, Arc<Logger>>>;
696696
/// # type PeerManager<B, F, FE, UL> = lightning::ln::peer_handler::SimpleArcPeerManager<SocketDescriptor, ChainMonitor<B, F, FE>, B, FE, Arc<UL>, Logger, F, StoreSync>;
697-
/// # type OutputSweeper<B, D, FE, F, O> = lightning::util::sweep::OutputSweeper<Arc<B>, Arc<D>, Arc<FE>, Arc<F>, Arc<StoreSync>, Arc<Logger>, Arc<O>>;
697+
/// # type OutputSweeper<B, D, FE, F, O> = lightning::util::sweep::OutputSweeper<Arc<B>, Arc<D>, Arc<FE>, Arc<F>, Arc<Store>, Arc<Logger>, Arc<O>>;
698698
///
699699
/// # struct Node<
700700
/// # B: lightning::chain::chaininterface::BroadcasterInterface + Send + Sync + 'static,
@@ -838,7 +838,7 @@ where
838838
LM::Target: ALiquidityManager,
839839
O::Target: 'static + OutputSpender,
840840
D::Target: 'static + ChangeDestinationSource,
841-
K::Target: 'static + KVStoreSync,
841+
K::Target: 'static + KVStore,
842842
{
843843
let mut should_break = false;
844844
let async_event_handler = |event| {

0 commit comments

Comments
 (0)