Struct DataStream 

pub struct DataStream { /* private fields */ }

Data stream manager.

Manages subscriptions and handles incoming data.

Implementations

impl DataStream

pub fn new(config: StreamConfig) -> Self

Create a new data stream.

pub fn state(&self) -> ConnectionState

Get connection state.

pub fn set_state(&self, state: ConnectionState)

Set connection state.

pub fn subscribe(&self, subscription: StreamSubscription) -> String

Subscribe to a data source.

pub fn unsubscribe(&self, id: &str)

Unsubscribe from a data source.

pub fn get_subscription(&self, id: &str) -> Option<StreamSubscription>

Get subscription by ID.

pub fn subscriptions(&self) -> Vec<StreamSubscription>

Get all active subscriptions.

pub fn get_data(&self, id: &str) -> Option<Value>

Get cached data for a subscription.

pub fn handle_message(&self, msg: StreamMessage) -> Option<StreamMessage>

Handle an incoming message.

pub fn take_outbox(&self) -> Vec<StreamMessage>

Take pending outbound messages.

pub fn send(&self, msg: StreamMessage)

Queue an outbound message.

pub fn reconnect_delay(&self) -> Duration

Get reconnection delay based on current attempts.

pub fn increment_reconnect_attempts(&self)

Increment reconnection attempts.

pub fn reset_reconnect_attempts(&self)

Reset reconnection attempts.

pub fn should_reconnect(&self) -> bool

Check if we should try to reconnect.

pub fn resubscribe_all(&self)

Resubscribe all subscriptions (after reconnect).

pub fn subscription_count(&self) -> usize

Number of active subscriptions.

pub fn clear(&self)

Clear all subscriptions and cache.

Trait Implementations

impl Default for DataStream

fn default() -> DataStream

Returns the “default value” for a type.