Struct StreamDomain 

pub struct StreamDomain { /* private fields */ }

Implementations

impl StreamDomain

pub fn new() -> Self

pub fn subscribe( &self, params: StreamSubscribeParams, principal: &str, ) -> Result<StreamSubscribeResult, ApiError>

pub fn get_subscription_principal( &self, subscription_id: &str, ) -> Option<String>

pub fn unsubscribe( &self, params: StreamUnsubscribeParams, ) -> Result<(), ApiError>

pub fn ack(&self, params: StreamAckParams) -> Result<(), ApiError>

pub fn live_receiver(&self) -> Receiver<StreamEventEnvelope>

pub fn has_subscription(&self, subscription_id: &str) -> bool

pub fn matches_subscription( &self, subscription_id: &str, event: &StreamEventEnvelope, ) -> bool

pub fn subscription_cursor_sequence( &self, subscription_id: &str, ) -> Result<u64, ApiError>

pub fn subscription_cursor( &self, subscription_id: &str, ) -> Result<String, ApiError>

pub fn replay_for_subscription( &self, subscription_id: &str, ) -> Result<ReplayBatch, ApiError>

pub fn keepalive_event( &self, subscription_id: &str, interval_ms: u64, ) -> StreamEventEnvelope

pub fn backpressure_event( &self, subscription_id: &str, dropped_count: usize, ) -> StreamEventEnvelope

pub fn publish( &self, topic: &str, resource_type: &str, resource_id: &str, payload: Value, )

pub fn publish_rpc_side_effect( &self, method: &str, params: &Value, result: &Value, )

Trait Implementations

impl Clone for StreamDomain

fn clone(&self) -> StreamDomain

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for StreamDomain

fn default() -> Self

Returns the “default value” for a type.