Struct ActiveCall 

pub struct ActiveCall {
    pub call_state: ActiveCallStateRef,
    pub cancel_token: CancellationToken,
    pub call_type: ActiveCallType,
    pub session_id: String,
    pub media_stream: Arc<MediaStream>,
    pub track_config: TrackConfig,
    pub event_sender: EventSender,
    pub app_state: AppState,
    pub invitation: Invitation,
    pub cmd_sender: CommandSender,
    pub dump_events: bool,
    pub server_side_track_id: TrackId,
}

Fields

call_state: ActiveCallStateRef

cancel_token: CancellationToken

call_type: ActiveCallType

session_id: String

media_stream: Arc<MediaStream>

track_config: TrackConfig

event_sender: EventSender

app_state: AppState

invitation: Invitation

cmd_sender: CommandSender

dump_events: bool

server_side_track_id: TrackId

Implementations

impl ActiveCall

pub fn new( call_type: ActiveCallType, cancel_token: CancellationToken, session_id: String, invitation: Invitation, app_state: AppState, track_config: TrackConfig, audio_receiver: Option<WebsocketBytesReceiver>, dump_events: bool, server_side_track_id: Option<TrackId>, extras: Option<HashMap<String, Value>>, sip_hangup_headers_template: Option<HashMap<String, String>>, ) -> Self

pub async fn enqueue_command(&self, command: Command) -> Result<()>

pub fn new_receiver(&self) -> ActiveCallReceiver

Create a new ActiveCallReceiver for this ActiveCall tokio::sync::broadcast not cached messages, so need to early create receiver before calling serve()

pub async fn serve(&self, receiver: ActiveCallReceiver) -> Result<()>

pub async fn cleanup(&self) -> Result<()>

pub fn get_callrecord(&self) -> Option<CallRecord>

pub async fn create_rtp_track( &self, track_id: TrackId, ssrc: u32, enable_srtp: Option<bool>, ) -> Result<RtcTrack>

pub async fn setup_track_with_stream( &self, option: &CallOption, track: Box<dyn Track>, ) -> Result<()>

pub async fn update_track_wrapper( &self, track: Box<dyn Track>, play_id: Option<String>, )

pub async fn create_websocket_track( &self, audio_receiver: WebsocketBytesReceiver, ) -> Result<Box<dyn Track>>

pub fn is_webrtc_sdp(sdp: &str) -> bool

Detect if SDP is WebRTC format

pub async fn setup_answer_track( &self, ssrc: u32, option: &CallOption, offer: String, ) -> Result<(String, Box<dyn Track>)>

pub async fn prepare_incoming_sip_track( &self, cancel_token: CancellationToken, call_state_ref: ActiveCallStateRef, track_id: &String, pending_dialog: PendingDialog, hangup_headers: Option<Vec<Header>>, ) -> Result<()>

Trait Implementations

impl Drop for ActiveCall

fn drop(&mut self)

Executes the destructor for this type.