Struct Listener 

pub struct Listener { /* private fields */ }

Pump.fun Listener

Example

use pump_sdk::listener::Listener;
#[tokio::main]
pub async fn main() {
    let listener = Listener::new(500, 500);
    let _ = listener
        .start(
            |_event| {
                // handle trade event
            },
            |_event| {
                // handle liquidity event
            },
        )
        .await;
    let _ = tokio::signal::ctrl_c().await;
}

Implementations

impl Listener

pub fn new(trade_channel: usize, liquidity_channel: usize) -> Self

pub fn from_url( rpc_url: String, ws_url: String, trade_channel: usize, liquidity_channel: usize, ) -> Self

pub fn from_client( client: Arc<RpcClient>, ws_url: String, trade_channel: usize, liquidity_channel: usize, ) -> Self

pub async fn start<T, L>( &self, trade_callback: T, liquidity_callback: L, ) -> Result<(), String>

where T: Fn(TradeEvent) + 'static + Send, L: Fn(LiquidityEvent) + 'static + Send,

start listener