cuprated::txpool::incoming_tx

Function handle_incoming_txs

Source
async fn handle_incoming_txs(
    __arg0: IncomingTxs,
    txs_being_handled: TxsBeingHandled,
    blockchain_context_cache: BlockChainContextService,
    tx_verifier_service: TxVerifierService<MapErr<BlockchainReadHandle, fn(_: RuntimeError) -> BoxError>>,
    txpool_write_handle: TxpoolWriteHandle,
    txpool_read_handle: TxpoolReadHandle,
    dandelion_pool_manager: DandelionPoolService<DandelionTx, [u8; 32], CrossNetworkInternalPeerId>,
) -> Result<(), IncomingTxError>
Expand description

Handles the incoming txs.