Struct webrtc_ice::agent::Agent

pub struct Agent { /* private fields */ }

Represents the ICE agent.

Implementations

impl Agent

pub async fn dial(
    &self,
    cancel_rx: Receiver<()>,
    remote_ufrag: String,
    remote_pwd: String
) -> Result<Arc<impl Conn>, Error>

Connects to the remote agent, acting as the controlling ice agent. The method blocks until at least one ice candidate pair has successfully connected.

The operation will be cancelled if cancel_rx either receives a message or its channel closes.

pub async fn accept(
    &self,
    cancel_rx: Receiver<()>,
    remote_ufrag: String,
    remote_pwd: String
) -> Result<Arc<impl Conn>, Error>

Connects to the remote agent, acting as the controlled ice agent. The method blocks until at least one ice candidate pair has successfully connected.

The operation will be cancelled if cancel_rx either receives a message or its channel closes.

impl Agent

pub async fn new(config: AgentConfig) -> Result<Self, Error>

Creates a new Agent.

pub async fn get_bytes_received(&self) -> usize

pub async fn get_bytes_sent(&self) -> usize

pub async fn on_connection_state_change(&self, f: OnConnectionStateChangeHdlrFn)

Sets a handler that is fired when the connection state changes.

pub async fn on_selected_candidate_pair_change(
    &self,
    f: OnSelectedCandidatePairChangeHdlrFn
)

Sets a handler that is fired when the final candidate pair is selected.

pub async fn on_candidate(&self, f: OnCandidateHdlrFn)

Sets a handler that is fired when new candidates gathered. When the gathering process complete the last candidate is nil.

pub async fn add_remote_candidate(
    &self,
    c: &Arc<dyn Candidate + Send + Sync>
) -> Result<(), Error>

Adds a new remote candidate.

pub async fn get_local_candidates(
    &self
) -> Result<Vec<Arc<dyn Candidate + Send + Sync>>, Error>

Returns the local candidates.

pub async fn get_local_user_credentials(&self) -> (String, String)

Returns the local user credentials.

pub async fn get_remote_user_credentials(&self) -> (String, String)

Returns the remote user credentials.

pub async fn close(&self) -> Result<(), Error>

Cleans up the Agent.

pub async fn get_selected_candidate_pair(&self) -> Option<Arc<CandidatePair>>

Returns the selected pair or nil if there is none

pub async fn set_remote_credentials(
    &self,
    remote_ufrag: String,
    remote_pwd: String
) -> Result<(), Error>

Sets the credentials of the remote agent.

pub async fn restart(&self, ufrag: String, pwd: String) -> Result<(), Error>

Restarts the ICE Agent with the provided ufrag/pwd If no ufrag/pwd is provided the Agent will generate one itself.

Restart must only be called when GatheringState is GatheringStateComplete a user must then call GatherCandidates explicitly to start generating new ones.

pub async fn gather_candidates(&self) -> Result<(), Error>

Initiates the trickle based gathering process.

pub async fn get_candidate_pairs_stats(&self) -> Vec<CandidatePairStats>

Returns a list of candidate pair stats.

pub async fn get_local_candidates_stats(&self) -> Vec<CandidateStats>

Returns a list of local candidates stats.

pub async fn get_remote_candidates_stats(&self) -> Vec<CandidateStats>

Returns a list of remote candidates stats.