Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages WebSocket subscriptions for real-time change notifications.

Examples

use kalam_client::KalamLinkClient;

let client = KalamLinkClient::builder().base_url("http://localhost:3000").build()?;

let mut subscription = client.live_events("SELECT * FROM messages").await?;

while let Some(event) = subscription.next().await {
    match event {
        Ok(change) => println!("Change detected: {:?}", change),
        Err(e) => eprintln!("Error: {}", e),
    }
}

Implementations

impl SubscriptionManager

pub async fn next(&mut self) -> Option<Result<ChangeEvent, KalamLinkError>>

Receive the next change event from the subscription.

Returns None when the connection is closed.

pub fn subscription_id(&self) -> &str

Get the subscription ID assigned by the server

pub fn timeouts(&self) -> &KalamLinkTimeouts

Get the configured timeouts

pub async fn close(&mut self) -> Result<(), KalamLinkError>

Close the subscription gracefully.

Safe to call multiple times — subsequent calls are no-ops.

pub fn is_closed(&self) -> bool

Returns true if close() has been called or Drop has run.

Trait Implementations

impl Drop for SubscriptionManager

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.