Struct Realtime

pub struct Realtime { /* private fields */ }

Realtime client for WebSocket subscriptions

Implementations

impl Realtime

pub fn new(config: Arc<SupabaseConfig>) -> Result<Self>

Create a new Realtime instance

pub async fn connect(&self) -> Result<()>

Connect to the realtime WebSocket

pub async fn disconnect(&self) -> Result<()>

Disconnect from the realtime WebSocket

pub async fn is_connected(&self) -> bool

Check if connected

pub fn channel(&self, topic: &str) -> SubscriptionBuilder

Create a new subscription builder

pub async fn subscribe<F>( &self, config: SubscriptionConfig, callback: F, ) -> Result<String>

where F: Fn(RealtimeMessage) + Send + Sync + 'static,

Subscribe to table changes

pub async fn unsubscribe(&self, subscription_id: &str) -> Result<()>

Unsubscribe from a topic

Trait Implementations

impl Clone for Realtime

fn clone(&self) -> Realtime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Realtime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.