summaryrefslogtreecommitdiff
path: root/client-native-lib/src/peer.rs
diff options
context:
space:
mode:
Diffstat (limited to 'client-native-lib/src/peer.rs')
-rw-r--r--client-native-lib/src/peer.rs15
1 files changed, 7 insertions, 8 deletions
diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs
index 023be1d..5f08061 100644
--- a/client-native-lib/src/peer.rs
+++ b/client-native-lib/src/peer.rs
@@ -87,21 +87,20 @@ impl Peer {
{
let weak = Arc::<Peer>::downgrade(&peer);
- peer.peer_connection.on_negotiation_needed(Box::new(move || {
- let peer = weak.upgrade().unwrap();
- Box::pin(async { peer.on_negotiation_needed().await })
- }))
+ peer.peer_connection
+ .on_negotiation_needed(Box::new(move || {
+ let peer = weak.upgrade().unwrap();
+ Box::pin(async { peer.on_negotiation_needed().await })
+ }))
}
{
let weak = Arc::<Peer>::downgrade(&peer);
peer.peer_connection
- .on_track(Box::new(move |track_remote, receiver| {
- let receiver = receiver.unwrap();
- let track_remote = track_remote.unwrap();
+ .on_track(Box::new(move |track_remote, receiver, _transceiver| {
let peer = weak.upgrade().unwrap();
Box::pin(async move {
- let id = &track_remote.stream_id().await;
+ let id = &track_remote.stream_id();
if let Some(res) = peer.remote_provided.read().await.get(id) {
info!("track for ({:?}) '{:?}'", res.id, res.label);
peer.inst