Struct TransactionSub 

pub struct TransactionSub<T: HasHeader + Decode> { /* private fields */ }

Subscription that mirrors Sub but yields decoded transactions via BlockWithTx.

Blocks that do not produce transactions matching the provided options are skipped automatically, ensuring callers only handle meaningful batches.

Implementations

impl<T: HasHeader + Decode> TransactionSub<T>

pub fn new(client: Client, opts: BlockExtOptionsSimple) -> Self

Creates a new TransactionSub subscription.

The client is cloned and no network calls are performed until TransactionSub::next is awaited. opts controls which transactions are retrieved from each block.

pub async fn next( &mut self, ) -> Result<(Vec<BlockTransaction<T>>, BlockInfo), Error>

Returns the next set of block transactions and the corresponding BlockInfo.

Returns

• Ok((Vec<BlockTransaction<T>>, BlockInfo)) when a block with matching transactions is found; the vector is guaranteed to be non-empty.
• Err(crate::Error) when fetching fails. The cursor rewinds to the same block so a subsequent call can retry.

On success the subscription advances to the next block height.

pub fn set_opts(&mut self, value: BlockExtOptionsSimple)

Replaces the transaction query options used on subsequent calls to TransactionSub::next. The change takes effect immediately.

pub fn use_best_block(&mut self, value: bool)

Follow best blocks instead of finalized ones for future iterations that have not yet been executed.

pub fn set_block_height(&mut self, value: u32)

Jump the cursor to a specific starting height. The next call to TransactionSub::next begins evaluating from value.

pub fn set_pool_rate(&mut self, value: Duration)

Change how often new blocks are polled when tailing the chain. Historical replays are not affected by this interval.

pub fn set_retry_on_error(&mut self, value: Option<bool>)

Controls retry behaviour for future RPC calls issued by the subscription.

• Some(true): force retries regardless of the client’s global setting.
• Some(false): disable retries entirely.
• None: defer to the client’s configuration.

pub fn should_retry_on_error(&self) -> bool

Returns true when this subscription will retry failed RPC calls.

Trait Implementations

impl<T: Clone + HasHeader + Decode> Clone for TransactionSub<T>

fn clone(&self) -> TransactionSub<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.