supabase-client-realtime 0.2.0

Realtime WebSocket client for supabase-client
Documentation

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_sdk::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?;