Struct Runner

pub struct Runner { /* private fields */ }

The runner will make the processing of the transactions in the queue.

Implementations

impl Runner

pub fn update_tip_height(&mut self, height: Height)

Update the tip_height field with a new height.

pub async fn run<Mempool, State, Tip>( self, mempool: Mempool, state: State, tip: Tip, network: Network, )

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + 'static, State: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static, Tip: ChainTip + Clone + Send + Sync + 'static,

Retry sending to mempool if needed.

Creates a loop that will run each time a new block is mined. In this loop, get the transactions that are in the queue and:

• Check if they are now in the mempool and if so, delete the transaction from the queue.
• Check if the transaction is now part of a block in the state and if so, delete the transaction from the queue.
• With the transactions left in the queue, retry sending them to the mempool ignoring the result of this operation.

Additionally, each iteration of the above loop, will receive and insert to the queue transactions that are pending in the channel.

Trait Implementations

impl Debug for Runner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.