Struct PubSubManager 

pub struct PubSubManager { /* private fields */ }

Pub/Sub Manager interface

Uses StreamableHTTP protocol for all operations. Pub/Sub is reactive by default - use subscribe() and subscribe_topic().

Implementations

impl PubSubManager

pub async fn publish( &self, topic: &str, data: Value, priority: Option<u8>, headers: Option<HashMap<String, String>>, ) -> Result<usize>

Publish a message to a topic

Returns

Returns the number of subscribers that received the message

Example

let count = client.pubsub().publish(
    "user.created",
    json!({"id": 123, "name": "Alice"}),
    Some(5),
    None
).await?;

pub async fn subscribe_topics( &self, subscriber_id: &str, topics: Vec<String>, ) -> Result<String>

Subscribe to topics

Supports wildcard patterns:

• user.* - single-level wildcard
• user.# - multi-level wildcard

Returns

Returns a subscription ID

pub async fn unsubscribe( &self, subscriber_id: &str, topics: Vec<String>, ) -> Result<()>

Unsubscribe from topics

pub async fn list_topics(&self) -> Result<Vec<String>>

List all active topics

impl PubSubManager

pub fn observe( &self, subscriber_id: impl Into<String>, topics: Vec<String>, ) -> (impl Stream<Item = PubSubMessage> + 'static, SubscriptionHandle)

Observe messages from Pub/Sub topics reactively using WebSocket

Returns a Stream of messages that are delivered in real-time via WebSocket. Supports wildcard patterns:

• user.* - single-level wildcard
• user.# - multi-level wildcard

Arguments

• subscriber_id - Unique subscriber identifier
• topics - List of topics to subscribe to (supports wildcards)

Example

use futures::StreamExt;
use synap_sdk::{SynapClient, SynapConfig};

let (mut stream, handle) = client.pubsub()
    .observe("subscriber-1", vec!["user.*".to_string(), "events.#".to_string()]);

// Process messages reactively
while let Some(message) = stream.next().await {
    tracing::info!("Received on {}: {:?}", message.topic, message.data);
}

// Stop subscribing
handle.unsubscribe();

pub fn observe_topic( &self, subscriber_id: impl Into<String>, topic: impl Into<String>, ) -> (impl Stream<Item = PubSubMessage> + 'static, SubscriptionHandle)

Observe messages from a single topic reactively

Convenience method for subscribing to a single topic.

Example

use futures::StreamExt;
use synap_sdk::{SynapClient, SynapConfig};

let (mut stream, handle) = client.pubsub()
    .observe_topic("subscriber-1", "user.events");

while let Some(message) = stream.next().await {
    tracing::info!("Received: {:?}", message);
}

handle.unsubscribe();

Trait Implementations

impl Clone for PubSubManager

fn clone(&self) -> PubSubManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.