Struct cuprate_dandelion_tower::pool::IncomingTx

pub struct IncomingTx<Tx, TxID, PID> {
    pub tx: Tx,
    pub tx_id: TxID,
    pub tx_state: TxState<PID>,
}

An incoming transaction for the DandelionPool to handle.

Users may notice there is no way to check if the dandelion-pool wants a tx according to an inventory message like seen in Bitcoin, only having a request for a full tx. Users should look in the public backing pool to handle inv messages, and request txs even if they are in the stem pool.

Fields

tx: Tx

The transaction.

It is recommended to put this in an Arc as it needs to be cloned to send to the backing tx pool and DandelionRouter

tx_id: TxID

The transaction ID.

tx_state: TxState<PID>

The routing state of this transaction.

Trait Implementations

impl<Tx, TxID, PID> Service<IncomingTx<Tx, TxID, PID>> for DandelionPoolService<Tx, TxID, PID>

where Tx: Clone + Send, TxID: Hash + Eq + Clone + Send + 'static, PID: Hash + Eq + Clone + Send + 'static,

type Response = ()

Responses given by the service.

type Error = DandelionPoolShutDown

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<DandelionPoolService<Tx, TxID, PID> as Service<IncomingTx<Tx, TxID, PID>>>::Response, <DandelionPoolService<Tx, TxID, PID> as Service<IncomingTx<Tx, TxID, PID>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: IncomingTx<Tx, TxID, PID>) -> Self::Future

Process the request and return the response asynchronously.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.