Struct SubscriptionBuilder

pub struct SubscriptionBuilder { /* private fields */ }

Subscription builder

Implementations

impl SubscriptionBuilder

pub fn table(self, table: &str) -> Self

Set the table to subscribe to

pub fn schema(self, schema: &str) -> Self

Set the schema

pub fn event(self, event: RealtimeEvent) -> Self

Set the event type to listen for

pub fn filter(self, filter: &str) -> Self

Set a filter for the subscription

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

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

Subscribe with the configured options