use pris::{self, EventManager, EventType, Message};
fn callback(msg: Message) -> bool {
println!("Seeked\nData: {:?}", msg);
true
}
#[tokio::test]
async fn test_evt_mgr() -> Result<(), Box<dyn std::error::Error>> {
let conn = pris::get_connection();
let mut manager = EventManager::new(&conn);
let _incoming_props = manager
.add_callback(EventType::PropertiesChanged, |msg| {
println!("PropertiesChanged\nData: {:?}", msg);
true
})
.await?;
let _incoming_seeked = manager.add_callback(EventType::Seeked, callback).await?;
tokio::signal::ctrl_c().await?;
manager.clear_callbacks().await?;
Ok(())
}