Struct StreamManager 

pub struct StreamManager { /* private fields */ }

Stream Manager interface

Uses StreamableHTTP protocol for all operations. Event Streams are reactive by default - use observe_events() or observe_event().

Implementations

impl StreamManager

pub async fn create_room( &self, room: &str, max_events: Option<usize>, ) -> Result<()>

Create a new stream room

pub async fn publish(&self, room: &str, event: &str, data: Value) -> Result<u64>

Publish an event to a stream

Returns

Returns the offset of the published event

Example

let offset = client.stream().publish(
    "chat-room",
    "message",
    json!({"user": "alice", "text": "Hello!"})
).await?;

pub async fn consume( &self, room: &str, offset: Option<u64>, limit: Option<usize>, ) -> Result<Vec<Event>>

Consume events from a stream

Arguments

• room - Stream room name
• offset - Starting offset (None = from beginning)
• limit - Maximum events to fetch

pub async fn stats(&self, room: &str) -> Result<StreamStats>

Get stream statistics

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

List all stream rooms

pub async fn delete_room(&self, room: &str) -> Result<()>

Delete a stream room

impl StreamManager

pub fn observe_events( &self, room: impl Into<String>, start_offset: Option<u64>, poll_interval: Duration, ) -> (impl Stream<Item = Event> + 'static, SubscriptionHandle)

Observe events from a stream room reactively

Returns a Stream of events that can be processed asynchronously. The stream will poll for new events at the specified interval.

Example

use futures::StreamExt;
use synap_sdk::{SynapClient, SynapConfig};
use std::time::Duration;

let (mut stream, handle) = client.stream()
    .observe_events("chat-room-1", Some(0), Duration::from_millis(100));

// Process events reactively
while let Some(event) = stream.next().await {
    println!("Event {}: {:?}", event.offset, event.data);
}

// Stop observing
handle.unsubscribe();

pub fn observe_event( &self, room: impl Into<String>, event_type: impl Into<String>, start_offset: Option<u64>, poll_interval: Duration, ) -> (impl Stream<Item = Event> + 'static, SubscriptionHandle)

Observe specific event types from a stream

Filters events by event type before delivering them.

Trait Implementations

impl Clone for StreamManager

fn clone(&self) -> StreamManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.