反应式 PostgreSQL for Rust

监视查询结果随新行的插入/更新/删除而变化

工作正在进行中

这个简单的示例以用户 postgres 的身份连接到本地主机。这将是可以配置的。

use reactive_pg::*;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
struct Foo {
    id: i32,
    name: String,
}

#[tokio::main]
async fn main() {
    "SELECT * from foo where id < 10"
        .watch::<Foo>(|event| println!("{:#?}", event))
        .await
	.await // <- The second await will block until the connection is dropped
	.unwrap();
}