use reactive_pg::*;use serde::{Deserialize,Serialize};#[derive(Serialize,Deserialize,Debug)]structFoo{id:i32,name:String,}#[tokio::main]asyncfnmain(){"SELECT * from foo where id < 10".watch::<Foo>(|event|println!("{:#?}", event)).await.await// <- The second await will block until the connection is dropped.unwrap();}