Skip to content

Commit d31760d

Browse files
committed
fix async kv store in sweeper
1 parent 4892285 commit d31760d

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

lightning/src/util/sweep.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -640,14 +640,12 @@ where
640640
) -> Pin<Box<dyn Future<Output = Result<(), io::Error>> + 'a + Send>> {
641641
let encoded = &sweeper_state.encode();
642642

643-
let result = self.kv_store.write(
643+
self.kv_store.write(
644644
OUTPUT_SWEEPER_PERSISTENCE_PRIMARY_NAMESPACE,
645645
OUTPUT_SWEEPER_PERSISTENCE_SECONDARY_NAMESPACE,
646646
OUTPUT_SWEEPER_PERSISTENCE_KEY,
647647
encoded,
648-
);
649-
650-
Box::pin(async move { result })
648+
)
651649
}
652650

653651
fn spend_outputs(

0 commit comments

Comments
 (0)