Supabase Realtime WebSocket client.
This crate implements the Phoenix Channels v1.0.0 protocol to provide real-time subscriptions for Postgres changes, broadcast messages, and presence tracking.
Usage
use supabase_client::prelude::*;
let realtime = client.realtime()?;
realtime.connect().await?;
let channel = realtime.channel("db-changes")
.on_postgres_changes(
PostgresChangesEvent::Insert,
PostgresChangesFilter::new("public", "messages"),
|payload| println!("New row: {:?}", payload.record),
)
.subscribe(|status, _err| println!("Status: {}", status))
.await?;