X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning%2Fsrc%2Futil%2Ftest_utils.rs;h=46a7bb340070618b85e69f860148b0319f14cea4;hb=8d50c919cfa3eee5eaf71d4b142ff5cbfddd4b56;hp=a34cb0cf323a337edc757579c761d1363948212b;hpb=2d4bf974e5b588ce93cc8f1e133cda30ca1d91ee;p=rust-lightning

diff --git a/lightning/src/util/test_utils.rs b/lightning/src/util/test_utils.rs
index a34cb0cf..46a7bb34 100644
--- a/lightning/src/util/test_utils.rs
+++ b/lightning/src/util/test_utils.rs
@@ -311,6 +311,17 @@ impl TestBroadcaster {
 	pub fn new(blocks: Arc<Mutex<Vec<(Block, u32)>>>) -> TestBroadcaster {
 		TestBroadcaster { txn_broadcasted: Mutex::new(Vec::new()), blocks }
 	}
+
+	pub fn txn_broadcast(&self) -> Vec<Transaction> {
+		self.txn_broadcasted.lock().unwrap().split_off(0)
+	}
+
+	pub fn unique_txn_broadcast(&self) -> Vec<Transaction> {
+		let mut txn = self.txn_broadcasted.lock().unwrap().split_off(0);
+		let mut seen = HashSet::new();
+		txn.retain(|tx| seen.insert(tx.txid()));
+		txn
+	}
 }
 
 impl chaininterface::BroadcasterInterface for TestBroadcaster {