Skip to content
This repository was archived by the owner on Mar 23, 2021. It is now read-only.

Commit 2f2d153

Browse files
workflowTobin Harding
andcommitted
Simplify parameter passing
Co-authored-by: Tobin Harding <tobin.harding@tenx.tech>
1 parent db6e01e commit 2f2d153

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

cnd/src/swap_protocols/rfc003/state_machine.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -280,15 +280,13 @@ pub fn create_swap<AL: Ledger, BL: Ledger, AA: Asset, BA: Asset>(
280280
impl Future<Item = (), Error = ()> + Send + 'static,
281281
impl Stream<Item = SwapStates<AL, BL, AA, BA>, Error = ()> + Send + 'static,
282282
) {
283-
let alpha_ledger_events = LedgerEventFutures::new(alpha_htlc_events);
284-
let beta_ledger_events = LedgerEventFutures::new(beta_htlc_events);
285283
let id = request.swap_id;
286284

287285
let (sender, receiver) = mpsc::unbounded();
288286

289287
let context = Context {
290-
alpha_ledger_events,
291-
beta_ledger_events,
288+
alpha_ledger_events: LedgerEventFutures::new(alpha_htlc_events),
289+
beta_ledger_events: LedgerEventFutures::new(beta_htlc_events),
292290
state_repo: Arc::new(sender),
293291
};
294292

0 commit comments

Comments
 (0)