INNER CODE UNIT · Rust

main

yourarj/token-listing-sniper-bot · src/bin/pending_tx_fetcher.rs:5

async fn main() {
    // tracing lib init
    let file_appender = tracing_appender::rolling::hourly("./", "pending-tx.log");
    let (non_blocking, _guard) = tracing_appender::non_blocking(file_appender);

    tracing_subscriber::fmt().with_writer(non_blocking).init();

    // env initialization
    let env = Env::new()
        .await
        .expect("Error occurred while initialization");

    // subscribe to pending transactions
    let mut stream = env
        .wss_provider
        .subscribe_pending_txs()
        .await
        .expect("Error while subscribing to pending transactions topic");

View source record →