Struct User 

pub struct User {
    remote_address: Arc<str>,
    media: ServerMediaNegotiation,
    cleanup_finished: bool,
}

Fields

remote_address: Arc<str>

media: ServerMediaNegotiation

cleanup_finished: bool

Implementations

impl User

pub async fn apply_client_envelope( &mut self, envelope: ClientEnvelope, ) -> Result<Vec<ServerEnvelope>, UserError>

async fn update_info( &self, info: UserInfo, ) -> Result<Vec<ServerEnvelope>, UserError>

async fn broadcast( &self, message: JsonPayload, ) -> Result<Vec<ServerEnvelope>, UserError>

async fn start_recording( &self, request_id: RequestId, options: RecordingOptions, ) -> Vec<ServerEnvelope>

async fn stop_recording(&self, request_id: RequestId) -> Vec<ServerEnvelope>

impl User

pub fn new(session: MediaSession, remote_address: Arc<str>) -> Self

pub(crate) fn room_id(&self) -> &str

pub(crate) const fn connection_id(&self) -> ConnectionId

pub(crate) fn user_id(&self) -> &UserId

pub(crate) fn remote_address(&self) -> &str

pub(crate) async fn is_current_connection(&self) -> bool

pub fn transport_disconnected(&self) -> bool

pub async fn start(&mut self) -> Result<Vec<ServerEnvelope>, UserError>

pub async fn close(&mut self)

pub(super) async fn reject_stale_connection(&self) -> Result<(), UserError>

impl User

pub(super) async fn complete_negotiation( &mut self, response_to: RequestId, response: ClientResponse, ) -> Result<Vec<ServerEnvelope>, UserError>

pub(super) async fn renegotiate( &mut self, ) -> Result<Vec<ServerEnvelope>, UserError>

pub(super) async fn set_publication_active( &mut self, stream_type: StreamType, active: bool, ) -> Result<Vec<ServerEnvelope>, UserError>

pub(super) async fn subscribe( &self, target_user_id: UserId, states: DownloadStates, ) -> Result<Vec<ServerEnvelope>, UserError>

pub(super) async fn run_initial_offer( &mut self, ) -> Result<Vec<ServerEnvelope>, UserError>

impl User

fn answer_error(&self, error: AnswerError) -> UserError

fn negotiation_error( &self, kind: NegotiationKind, response_to: Option<&RequestId>, error: SessionError, ) -> UserError

fn publish_error( &self, stream_type: StreamType, error: SessionError, ) -> UserError

fn subscribe_error( &self, target_user_id: &UserId, error: SessionError, ) -> UserError

impl User

pub(crate) async fn apply_room_outbound( &mut self, outbound: UserOutbound, ) -> Result<Vec<ServerEnvelope>, UserError>

Trait Implementations

impl Drop for User

fn drop(&mut self)

Executes the destructor for this type.