Skip to content

Commit 9eeba7e

Browse files
AJStoneweemattsseshekhirin
authored
feat(transaction-pool): add new_blob_pool_transactions_listener (#20216)
Co-authored-by: Matthias Seitz <[email protected]> Co-authored-by: Alexey Shekhirin <[email protected]>
1 parent 0085acc commit 9eeba7e

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

crates/transaction-pool/src/traits.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -283,6 +283,16 @@ 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(
291+
&self,
292+
) -> NewSubpoolTransactionStream<Self::Transaction> {
293+
NewSubpoolTransactionStream::new(self.new_transactions_listener(), SubPool::Blob)
294+
}
295+
286296
/// Returns the _hashes_ of all transactions in the pool that are allowed to be propagated.
287297
///
288298
/// This excludes hashes that aren't allowed to be propagated.

0 commit comments

Comments
 (0)