Skip to content

Commit 1f59bbe

Browse files
committed
Use async kv store with OutputSweeper
1 parent c5eeebb commit 1f59bbe

File tree

2 files changed

+145
-106
lines changed

2 files changed

+145
-106
lines changed

lightning-background-processor/src/lib.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -40,9 +40,9 @@ 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::{KVStore, Persister};
4344
#[cfg(feature = "std")]
44-
use lightning::util::persist::PersisterSync;
45-
use lightning::util::persist::{KVStoreSync, Persister};
45+
use lightning::util::persist::{KVStoreSync, PersisterSync};
4646
use lightning::util::sweep::OutputSweeper;
4747
#[cfg(feature = "std")]
4848
use lightning::util::sweep::OutputSweeperSync;
@@ -696,7 +696,7 @@ use futures_util::{dummy_waker, OptionalSelector, Selector, SelectorOutput};
696696
/// # type LiquidityManager<B, F, FE> = lightning_liquidity::LiquidityManager<Arc<lightning::sign::KeysManager>, Arc<ChannelManager<B, F, FE>>, Arc<F>>;
697697
/// # type Scorer = RwLock<lightning::routing::scoring::ProbabilisticScorer<Arc<NetworkGraph>, Arc<Logger>>>;
698698
/// # type PeerManager<B, F, FE, UL> = lightning::ln::peer_handler::SimpleArcPeerManager<SocketDescriptor, ChainMonitor<B, F, FE>, B, FE, Arc<UL>, Logger, F, StoreSync>;
699-
/// # 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>>;
699+
/// # 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>>;
700700
///
701701
/// # struct Node<
702702
/// # B: lightning::chain::chaininterface::BroadcasterInterface + Send + Sync + 'static,
@@ -840,7 +840,7 @@ where
840840
LM::Target: ALiquidityManager,
841841
O::Target: 'static + OutputSpender,
842842
D::Target: 'static + ChangeDestinationSource,
843-
K::Target: 'static + KVStoreSync,
843+
K::Target: 'static + KVStore,
844844
{
845845
let mut should_break = false;
846846
let async_event_handler = |event| {

0 commit comments

Comments
 (0)