diff options
| author | metamuffin <metamuffin@disroot.org> | 2022-09-15 19:08:08 +0200 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2022-09-15 19:08:08 +0200 |
| commit | 1286385698c4d09876abf29cb5ed595f7cfe1a8f (patch) | |
| tree | 3adbe53a1393be941c7459c802f7238c5d0e2d64 /client-native-lib/src/peer.rs | |
| parent | 7c68bdb983c2f52fb09e1a5418e5bc44d3b44b30 (diff) | |
| download | keks-meet-1286385698c4d09876abf29cb5ed595f7cfe1a8f.tar keks-meet-1286385698c4d09876abf29cb5ed595f7cfe1a8f.tar.bz2 keks-meet-1286385698c4d09876abf29cb5ed595f7cfe1a8f.tar.zst | |
rift works.
Diffstat (limited to 'client-native-lib/src/peer.rs')
| -rw-r--r-- | client-native-lib/src/peer.rs | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs index 280cc06..d6ca308 100644 --- a/client-native-lib/src/peer.rs +++ b/client-native-lib/src/peer.rs @@ -48,10 +48,10 @@ impl Peer { .await; { - let peer2 = peer.clone(); + let weak = Arc::<Peer>::downgrade(&peer); peer.peer_connection .on_ice_candidate(box move |c| { - let peer = peer2.clone(); + let peer = weak.upgrade().unwrap(); Box::pin(async move { if let Some(c) = c { peer.on_ice_candidate(c).await @@ -62,10 +62,10 @@ impl Peer { } { - let peer2 = peer.clone(); + let weak = Arc::<Peer>::downgrade(&peer); peer.peer_connection .on_negotiation_needed(box move || { - let peer = peer2.clone(); + let peer = weak.upgrade().unwrap(); Box::pin(async { peer.on_negotiation_needed().await }) }) .await; @@ -114,7 +114,7 @@ impl Peer { } pub async fn offer(&self) { - info!("sending offer"); + info!("({}) sending offer", self.id); let offer = self.peer_connection.create_offer(None).await.unwrap(); self.peer_connection .set_local_description(offer.clone()) @@ -127,7 +127,7 @@ impl Peer { .await } pub async fn on_offer(&self, offer: RTCSessionDescriptionInit) { - info!("received offer"); + info!("({}) received offer", self.id); let offer = RTCSessionDescription::offer(offer.sdp).unwrap(); self.peer_connection .set_remote_description(offer) @@ -136,7 +136,7 @@ impl Peer { self.answer().await } pub async fn answer(&self) { - info!("sending answer"); + info!("({}) sending answer", self.id); let offer = self.peer_connection.create_answer(None).await.unwrap(); self.peer_connection .set_local_description(offer.clone()) @@ -149,7 +149,7 @@ impl Peer { .await } pub async fn on_answer(&self, answer: RTCSessionDescriptionInit) { - info!("received answer"); + info!("({}) received answer", self.id); let offer = RTCSessionDescription::answer(answer.sdp).unwrap(); self.peer_connection .set_remote_description(offer) |