Skip to content

Commit a2e573a

Browse files
committed
add new_blob_pool_transactions_listener
1 parent 28d6996 commit a2e573a

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

crates/transaction-pool/src/traits.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -283,6 +283,14 @@ pub trait TransactionPool: Clone + Debug + Send + Sync {
283283
NewSubpoolTransactionStream::new(self.new_transactions_listener(), SubPool::Queued)
284284
}
285285

286+
/// Returns a new Stream that yields new transactions added to the blob sub-pool.
287+
///
288+
/// This is a convenience wrapper around [`Self::new_transactions_listener`] that filters for
289+
/// [`SubPool::Blob`](crate::SubPool).
290+
fn new_blob_pool_transactions_listener(&self) -> NewSubpoolTransactionStream<Self::Transaction> {
291+
NewSubpoolTransactionStream::new(self.new_transactions_listener(), SubPool::Blob)
292+
}
293+
286294
/// Returns the _hashes_ of all transactions in the pool that are allowed to be propagated.
287295
///
288296
/// This excludes hashes that aren't allowed to be propagated.

0 commit comments

Comments
 (0)