Struct cuprate_dandelion_tower::pool::IncomingTx

pub struct IncomingTx<Tx, TxId, PeerId> { /* private fields */ }

An incoming transaction that has gone through the preprocessing stage.

Trait Implementations

impl<Tx, TxId, PeerId> Service<IncomingTx<Tx, TxId, PeerId>> for DandelionPoolService<Tx, TxId, PeerId>

where Tx: Clone + Send, TxId: Hash + Eq + Clone + Send + 'static, PeerId: 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, PeerId> as Service<IncomingTx<Tx, TxId, PeerId>>>::Response, <DandelionPoolService<Tx, TxId, PeerId> as Service<IncomingTx<Tx, TxId, PeerId>>>::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, PeerId>) -> 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.