Struct RoomUserOperation 

pub(crate) struct RoomUserOperation<'a> {
    pub room: &'a Room,
    pub user_id: &'a UserId,
    pub connection_id: ConnectionId,
    pub media_transport: &'a MediaTransport,
}

Fields

room: &'a Room

user_id: &'a UserId

connection_id: ConnectionId

media_transport: &'a MediaTransport

Implementations

impl RoomUserOperation<'_>

async fn stage_validated_publish( self, validated_descriptor: ValidatedPublish, ) -> Result<PublishStageOutcome, TransportAdapterError>

pub(crate) async fn start_publish( self, intent: &SourcePublishIntent, can_stage: bool, ) -> Result<PublishIntentOutcome, TransportAdapterError>

pub async fn rollback_staged_publish(self, stream_id: &UserStreamId) -> bool

pub(crate) async fn deactivate_publication( self, intent: &SourceDeactivateIntent, ) -> DeactivateIntentOutcome

pub(crate) async fn commit_staged_publishes( self, applied_answer: &AppliedSessionAnswer, )

Resolves this connection’s staged publishes against an accepted answer.

async fn execute_publication_activity(self, commit: ProducerActivityCommit)

impl RoomUserOperation<'_>

pub(crate) async fn apply_session_negotiated( self, capabilities: MediaCapabilities, declined_consumers: &[TransportMediaId], ) -> Option<()>

pub(crate) async fn apply_session_refreshed( self, declined_consumers: &[TransportMediaId], ) -> Option<()>

async fn apply_receiver_readiness( self, declined_consumers: &[TransportMediaId], ) -> Option<()>

pub(crate) async fn apply_receiver_intent( self, target_user_id: &UserId, intents: &BTreeMap<UserStreamId, SourceSubscriptionIntent>, ) -> Option<()>

Trait Implementations

impl<'a> Clone for RoomUserOperation<'a>

fn clone(&self) -> RoomUserOperation<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for RoomUserOperation<'a>