Struct TradeEventListener 

pub struct TradeEventListener { /* private fields */ }

Event listener for transaction monitoring

Implementations

impl TradeEventListener

pub fn new(evm: Arc<Evm>) -> Self

pub async fn watch_large_transactions( &self, min_value: U256, poll_interval_secs: u64, ) -> Result<Receiver<TransactionWithReceipt>, EvmError>

Watch for large transactions based on value threshold

Example

let mut receiver = event_listener.watch_large_transactions(
    U256::from(10u64.pow(18)), // 1 ETH
    3
).await?;

while let Some(tx) = receiver.recv().await {
    println!("Large transaction: {:?}", tx.transaction.hash);
}

pub async fn watch_large_transfers( &self, token_address: Option<String>, min_value: U256, poll_interval_secs: u64, ) -> Result<Receiver<LargeTransferEvent>, EvmError>

Watch for large ERC20 transfer events

Example

let token_address = "0x...".to_string();
let mut receiver = event_listener.watch_large_transfers(
    Some(token_address),
    U256::from(1000 * 10u64.pow(18)), // 1000 tokens
    3
).await?;

pub async fn watch_large_token_transfers( &self, token_address: String, min_value: U256, ) -> Result<Receiver<LargeTransferEvent>, EvmError>

Watch large transfers for a specific token

pub async fn watch_all_large_transfers( &self, min_value: U256, ) -> Result<Receiver<LargeTransferEvent>, EvmError>

Watch large transfers for all tokens

pub async fn watch_address_events( &self, address: String, ) -> Result<Receiver<Log>, EvmError>

Watch all events for a specific address

Example

let mut receiver = event_listener.watch_address_events(
    "0x...".to_string()
).await?;

pub async fn watch_transfer_events( &self, address: String, ) -> Result<Receiver<TransferEvent>, EvmError>

Watch transfer events for a specific address

pub async fn watch_address_events_with_config( &self, address: String, poll_interval_secs: u64, max_blocks_per_poll: u64, ) -> Result<Receiver<Log>, EvmError>

Watch address events with custom configuration

pub fn stop_event_listener(receiver: Receiver<Log>)