Struct node_bench::construct::Transactions

pub struct Transactions(Vec<Arc<PoolTransaction>>);

Trait Implementations

impl Clone for Transactions

fn clone(&self) -> Transactions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Transactions

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

Formats the value using the given formatter.

impl TransactionPool for Transactions

fn submit_at(
    &self,
    _at: &BlockId<Self::Block>,
    _source: TransactionSource,
    _xts: Vec<TransactionFor<Self>>
) -> PoolFuture<Vec<Result<Hash, Self::Error>>, Self::Error>

Returns a future that imports a bunch of unverified transactions to the pool.

fn submit_one(
    &self,
    _at: &BlockId<Self::Block>,
    _source: TransactionSource,
    _xt: TransactionFor<Self>
) -> PoolFuture<TxHash<Self>, Self::Error>

Returns a future that imports one unverified transaction to the pool.

type Block = Block

Block type.

type Hash = Hash

Transaction hash type.

type InPoolTransaction = PoolTransaction

In-pool transaction type.

type Error = Error

Error type.

fn submit_and_watch(
    &self,
    _at: &BlockId<Self::Block>,
    _source: TransactionSource,
    _xt: TransactionFor<Self>
) -> PoolFuture<Box<TransactionStatusStreamFor<Self>>, Self::Error>

Returns a future that import a single transaction and starts to watch their progress in the pool.

fn ready_at(
    &self,
    _at: NumberFor<Self::Block>
) -> Pin<Box<dyn Future<Output = Box<dyn Iterator<Item = Arc<Self::InPoolTransaction>> + Send>> + Send>>

Get an iterator for ready transactions ordered by priority.

fn ready(&self) -> Box<dyn Iterator<Item = Arc<Self::InPoolTransaction>> + Send>

Get an iterator for ready transactions ordered by priority.

fn remove_invalid(
    &self,
    _hashes: &[TxHash<Self>]
) -> Vec<Arc<Self::InPoolTransaction>>

Remove transactions identified by given hashes (and dependent transactions) from the pool.

fn status(&self) -> PoolStatus

Returns pool status.

fn import_notification_stream(&self) -> ImportNotificationStream<TxHash<Self>>

Return an event stream of transactions imported to the pool.

fn on_broadcasted(&self, _propagations: HashMap<TxHash<Self>, Vec<String>>)

Notify the pool about transactions broadcast.

fn hash_of(&self, _xt: &TransactionFor<Self>) -> TxHash<Self>

Returns transaction hash

fn ready_transaction(
    &self,
    _hash: &TxHash<Self>
) -> Option<Arc<Self::InPoolTransaction>>

Return specific ready transaction by hash, if there is one.