Struct ThreadStateManager 

pub struct ThreadStateManager { /* private fields */ }

Implementations

impl ThreadStateManager

pub async fn subscribe( &self, thread_id: impl Into<String>, connection_id: ConnectionId, )

pub async fn subscribers(&self, thread_id: &str) -> Vec<ConnectionId>

pub async fn set_active_turn( &self, thread_id: impl Into<String>, active_turn: ActiveTurn, )

pub async fn active_turn(&self, thread_id: &str) -> Option<ActiveTurn>

pub async fn clear_active_turn(&self, thread_id: &str, turn_id: &str)

pub async fn cancel_turn(&self, thread_id: &str, turn_id: &str) -> bool

pub async fn set_pending_approval( &self, thread_id: impl Into<String>, turn_id: impl Into<String>, request_id: impl Into<String>, )

pub async fn pending_approval(&self, thread_id: &str) -> Option<PendingApproval>

pub async fn clear_pending_approval(&self, thread_id: &str, request_id: &str)

Trait Implementations

impl Clone for ThreadStateManager

fn clone(&self) -> ThreadStateManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ThreadStateManager

fn default() -> ThreadStateManager

Returns the “default value” for a type.