f Account for BroadcasterInterface taking a slice

Author: tnull

src/event.rs

@@ -564,7 +564,7 @@ where
 					&Secp256k1::new(),
 				);
 				match res {
-					Ok(spending_tx) => self.wallet.broadcast_transaction(&spending_tx),
+					Ok(spending_tx) => self.wallet.broadcast_transactions(&[&spending_tx]),
 					Err(err) => {
 						log_error!(self.logger, "Error spending outputs: {:?}", err);
 					}

src/wallet.rs

@@ -249,7 +249,7 @@ where
 			psbt.extract_tx()
 		};
 
-		self.broadcast_transaction(&tx);
+		self.broadcast_transactions(&[&tx]);
 
 		let txid = tx.txid();
 
@@ -305,18 +305,31 @@ where
 	D: BatchDatabase,
 	L::Target: Logger,
 {
-	fn broadcast_transaction(&self, tx: &Transaction) {
+	fn broadcast_transactions(&self, txs: &[&Transaction]) {
 		let locked_runtime = self.runtime.read().unwrap();
 		if locked_runtime.as_ref().is_none() {
 			log_error!(self.logger, "Failed to broadcast transaction: No runtime.");
 			return;
 		}
 
 		let res = tokio::task::block_in_place(move || {
-			locked_runtime
-				.as_ref()
-				.unwrap()
-				.block_on(async move { self.blockchain.broadcast(tx).await })
+			locked_runtime.as_ref().unwrap().block_on(async move {
+				let mut handles = Vec::new();
+				for tx in txs {
+					handles.push(self.blockchain.broadcast(tx));
+				}
+
+				for handle in handles {
+					match handle.await {
+						Ok(_) => {}
+						Err(err) => {
+							return Err(err);
+						}
+					}
+				}
+
+				Ok(())
+			})
 		});
 
 		match res {