Struct SessionController 

pub struct SessionController { /* private fields */ }

Implementations

impl SessionController

pub fn builder<P, V>() -> SessionBuilder<P, V, ForController>

where P: TokenProvider + Send + Sync + Clone + 'static, V: Verifier + Send + Sync + Clone + 'static,

Returns a new SessionBuilder for constructing a SessionController

pub fn id(&self) -> u32

getters

pub fn source(&self) -> &ProtoName

pub fn dst(&self) -> &ProtoName

pub fn session_type(&self) -> ProtoSessionType

pub fn metadata(&self) -> HashMap<String, String>

pub fn session_config(&self) -> SessionConfig

pub fn is_initiator(&self) -> bool

pub async fn participants_list(&self) -> Result<Vec<ProtoName>, SessionError>

pub async fn on_message_from_app( &self, message: Message, ) -> Result<CompletionHandle, SessionError>

Send a message to the controller for processing

pub async fn on_message_from_slim( &self, message: Message, ) -> Result<(), SessionError>

Send a message to the controller for processing

pub async fn on_error_message_from_slim( &self, error: SessionError, ) -> Result<(), SessionError>

Send an error message to the controller for processing

pub fn close(&self) -> Result<JoinHandle<()>, SessionError>

pub async fn publish_message( &self, message: Message, ) -> Result<CompletionHandle, SessionError>

pub async fn publish_to( &self, name: &ProtoName, forward_to: u64, blob: Vec<u8>, payload_type: Option<String>, metadata: Option<HashMap<String, String>>, ) -> Result<CompletionHandle, SessionError>

Publish a message to a specific connection (forward_to)

pub async fn publish( &self, name: &ProtoName, blob: Vec<u8>, payload_type: Option<String>, metadata: Option<HashMap<String, String>>, ) -> Result<CompletionHandle, SessionError>

Publish a message to a specific app name

pub async fn publish_with_flags( &self, name: &ProtoName, flags: SlimHeaderFlags, blob: Vec<u8>, payload_type: Option<String>, metadata: Option<HashMap<String, String>>, ) -> Result<CompletionHandle, SessionError>

Publish a message with specific flags

pub async fn invite_participant( &self, destination: &ProtoName, ) -> Result<CompletionHandle, SessionError>

pub async fn remove_participant( &self, destination: &ProtoName, ) -> Result<CompletionHandle, SessionError>

Trait Implementations

impl Drop for SessionController

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.