f Account for BroadcasterInterface taking a slice

Author: tnull

src/event.rs

@@ -565,7 +565,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

@@ -254,7 +254,7 @@ where
 			psbt.extract_tx()
 		};
 
-		self.broadcast_transaction(&tx);
+		self.broadcast_transactions(&[&tx]);
 
 		let txid = tx.txid();
 
@@ -308,26 +308,31 @@ impl<D> BroadcasterInterface for Wallet<D>
 where
 	D: BatchDatabase,
 {
-	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 })
-		});
+		let bcast_logger = Arc::clone(&self.logger);
+		tokio::task::block_in_place(move || {
+			locked_runtime.as_ref().unwrap().block_on(async move {
+				let mut handles = Vec::new();
+				for tx in txs {
+					handles.push(self.blockchain.broadcast(tx));
+				}
 
-		match res {
-			Ok(_) => {}
-			Err(err) => {
-				log_error!(self.logger, "Failed to broadcast transaction: {}", err);
-			}
-		}
+				for handle in handles {
+					match handle.await {
+						Ok(_) => {}
+						Err(err) => {
+							log_error!(bcast_logger, "Failed to broadcast transaction: {}", err);
+						}
+					}
+				}
+			})
+		});
 	}
 }