Struct WithTimeout

pub struct WithTimeout<T> { /* private fields */ }

Wrapper type for any type implementing XandAPIClientTrait that adds a timeout to all requests.

Implementations

impl<T> WithTimeout<T>

pub fn new(client: T, timeout: Duration) -> Self

Wraps a XandAPIClientTrait client and returns a client that applies the given timeout to all requests.

Trait Implementations

impl<T: Debug> Debug for WithTimeout<T>

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

Formats the value using the given formatter.

impl<T: XandApiClientTrait> XandApiClientTrait for WithTimeout<T>

fn submit_transaction<'life0, 'async_trait>( &'life0 self, issuer: Address, txn: XandTransaction, ) -> Pin<Box<dyn Future<Output = Result<TransactionStatusStream, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submit a transaction to the API, where it will be signed and then sent to the blockchain

fn submit_transaction_wait<'life0, 'async_trait>( &'life0 self, issuer: Address, txn: XandTransaction, ) -> Pin<Box<dyn Future<Output = Result<TransactionUpdate, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Like submit_transaction, but rather than returning a stream, returns a future that completes once the the transaction has been committed or invalidated (not finalized).

fn submit_transaction_wait_final<'life0, 'async_trait>( &'life0 self, issuer: Address, txn: XandTransaction, ) -> Pin<Box<dyn Future<Output = Result<TransactionUpdate, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submits a transaction and returns its final status (which, in the case of a valid transaction, should eventually be Finalized).

fn get_transaction_details<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TransactionId, ) -> Pin<Box<dyn Future<Output = Result<Transaction, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch the details of a particular transaction

fn get_transaction_history<'life0, 'life1, 'async_trait>( &'life0 self, paging: Option<Paging>, filter: &'life1 TransactionFilter, ) -> Pin<Box<dyn Future<Output = Result<Paginated<Vec<Transaction>>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Query transaction history

fn get_balance<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<u128>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch the balance (in USD cents) held by an address

fn get_total_issuance<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<TotalIssuance, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_current_block<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Blockstamp, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets the most current block and timestamp with a staleness indicator

fn get_address_transactions<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, paging: Option<Paging>, ) -> Pin<Box<dyn Future<Output = Result<TransactionHistoryPage, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch all transactions which are relevant to the provided address

fn get_pending_create_requests<'life0, 'async_trait>( &'life0 self, paging: Option<Paging>, ) -> Pin<Box<dyn Future<Output = Result<Paginated<Vec<PendingCreateRequest>>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request the current pending create requests

fn get_pending_redeem_requests<'life0, 'async_trait>( &'life0 self, paging: Option<Paging>, ) -> Pin<Box<dyn Future<Output = Result<Paginated<Vec<PendingRedeemRequest>>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request the current pending redeem requests

fn propose_action<'life0, 'async_trait>( &'life0 self, issuer: Address, admin_txn: AdministrativeTransaction, ) -> Pin<Box<dyn Future<Output = Result<TransactionStatusStream, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submit a proposal for an action to be voted on by network

fn vote_on_proposal<'life0, 'async_trait>( &'life0 self, issuer: Address, vote_proposal: VoteProposal, ) -> Pin<Box<dyn Future<Output = Result<TransactionStatusStream, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submit vote on specific proposal by id

fn get_proposal<'life0, 'async_trait>( &'life0 self, id: u32, ) -> Pin<Box<dyn Future<Output = Result<Proposal, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get specific proposal by id

fn get_all_proposals<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Proposal>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all non-expired proposals

fn get_members<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Address>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get list of members

fn get_authority_keys<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Address>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get list of validators

fn get_trustee<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Address, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get trustee address

fn get_allowlist<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<(Address, CidrBlock)>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get allowlisted CIDR blocks per address

fn get_limited_agent<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Address>, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get Limited Agent address if one exists

fn get_validator_emission_rate<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ValidatorEmissionRate, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get current Validator emission rate setting

fn get_validator_emission_progress<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<ValidatorEmissionProgress, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the current progress of an individual validator toward an emission

fn get_pending_create_request_expire_time<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the current pending create request expire time in milliseconds

fn check_health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HealthResponse, XandApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Health check

fn with_timeout(self, timeout: Duration) -> WithTimeout<Self>

where Self: Sized,

Returns a client that behaves like self and applies the given timeout to every asynchronous operation.