cargo add pglite-rs --features replica,multiple-process

use pglite::{PGlite, Replica, ReplicaConfig, SslMode};

let db = PGlite::open_multi_process("./replica", Default::default()).await?;

let replica = Replica::start(
    db.clone(),
    ReplicaConfig {
        host: "127.0.0.1".into(),
        port: 5432,
        user: "postgres".into(),
        password: "postgres".into(),
        database: "app".into(),
        publication: "app_pub".into(),
        slot_name: "app_slot".into(),
        sslmode: SslMode::Disable,
        ..Default::default()
    }
).await?;

let mut rx = replica.subscribe();

while let Some(tx) = rx.recv().await {
    println!("xid={} lsn={}", tx.xid, tx.commit_lsn.to_pg_str());
    for change in &tx.changes {
        println!("{change:?}");
    }
}