events.rs

let (_client, rx) = PubsubClient::logs_subscribe(
    "ws://127.0.0.1:8900",
    RpcTransactionLogsFilter::Mentions(vec![self.program.id().to_string()]),
    RpcTransactionLogsConfig { commitment: None },
)?;
std::thread::spawn(move || loop {
    let ev = rx.recv().unwrap();
    println!("EV: {:#?}", ev);
});