Struct WsProvider

pub struct WsProvider { /* private fields */ }

Implementations

impl WsProvider

pub async fn request( &self, operation: Operation, params: impl Serialize, format: Format, deltas: bool, ) -> StreamResponse<Vec<u8>>

pub fn ready(&self) -> bool

Returns true if the WS connection is active, false otherwise

Trait Implementations

impl BtcProvider for WsProvider

fn get_btc_blocks_by_format<'life0, 'async_trait>( &'life0 self, request: GetBtcBlocksRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_btc_txs_by_format<'life0, 'async_trait>( &'life0 self, request: GetBtcTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

impl ChainProvider for WsProvider

fn get_blocks_by_format<'life0, 'async_trait>( &'life0 self, request: GetBlocksRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_logs_by_format<'life0, 'async_trait>( &'life0 self, request: GetLogsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_txs_by_format<'life0, 'async_trait>( &'life0 self, request: GetTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_transfers_by_format<'life0, 'async_trait>( &'life0 self, request: GetTransfersRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

impl Clone for WsProvider

fn clone(&self) -> WsProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CurveProvider for WsProvider

fn get_tokens_by_format<'life0, 'async_trait>( &'life0 self, request: GetCrvTokenRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_pools_by_format<'life0, 'async_trait>( &'life0 self, request: GetCrvPoolRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_prices_by_format<'life0, 'async_trait>( &'life0 self, request: GetCrvPriceRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

impl Debug for WsProvider

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

Formats the value using the given formatter.

impl Erc20Provider for WsProvider

fn get_erc20_by_format<'life0, 'async_trait>( &'life0 self, request: GetErc20Request, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_erc20_approval_by_format<'life0, 'async_trait>( &'life0 self, request: GetErc20ApprovalsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_erc20_transfers_by_format<'life0, 'async_trait>( &'life0 self, request: GetErc20TransferssRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

impl MoveProvider for WsProvider

fn get_move_logs_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveLogsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_logs_decoded_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveLogsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_txs_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_txs_decoded_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_receipts_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveReceiptsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_receipts_decoded_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveReceiptsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_modules_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveReceiptsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_fa_tokens_by_format<'life0, 'async_trait>( &'life0 self, request: GetTokensRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_coins_by_format<'life0, 'async_trait>( &'life0 self, request: GetTokensRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_interest_v1_pools_by_format<'life0, 'async_trait>( &'life0 self, request: GetPoolsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_interest_v1_liquidity_by_format<'life0, 'async_trait>( &'life0 self, request: GetLiquidityRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_interest_v1_swaps_by_format<'life0, 'async_trait>( &'life0 self, request: GetSwapsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_arche_collaterals_by_format<'life0, 'async_trait>( &'life0 self, request: GetCollateralsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_arche_loans_by_format<'life0, 'async_trait>( &'life0 self, request: GetLoansRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_arche_positions_by_format<'life0, 'async_trait>( &'life0 self, request: GetPositionsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_pyth_by_format<'life0, 'async_trait>( &'life0 self, request: GetPricesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_move_balances_by_format<'life0, 'async_trait>( &'life0 self, request: GetBalancesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

const MOVE_VALID_CHAINS: [ChainId; 3] = _

fn check_chain(&self, chains: &HashSet<ChainId>) -> Result<()>

impl Provider for WsProvider

fn try_new<'async_trait>( endpoint: String, is_secure: bool, username: Option<String>, password: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Self>> + Send + 'async_trait>>

where Self: 'async_trait,

fn get_status_by_format<'life0, 'async_trait>( &'life0 self, format: Format, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

impl UniswapV2Provider for WsProvider

fn get_pairs_by_format<'life0, 'async_trait>( &'life0 self, request: GetPairsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_prices_by_format<'life0, 'async_trait>( &'life0 self, request: GetPricesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

impl UniswapV3Provider for WsProvider

fn get_fees_by_format<'life0, 'async_trait>( &'life0 self, request: GetFeesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_pools_by_format<'life0, 'async_trait>( &'life0 self, request: GetPoolsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_positions_by_format<'life0, 'async_trait>( &'life0 self, request: GetPositionsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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

fn get_prices_by_format<'life0, 'async_trait>( &'life0 self, request: GetPricesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

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