diff options
Diffstat (limited to 'client-native-lib/src/peer.rs')
| -rw-r--r-- | client-native-lib/src/peer.rs | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs index 82c7c94..b271318 100644 --- a/client-native-lib/src/peer.rs +++ b/client-native-lib/src/peer.rs @@ -102,6 +102,34 @@ impl Peer { { let weak = Arc::<Peer>::downgrade(&peer); peer.peer_connection + .on_track(box move |track_remote, receiver| { + let receiver = receiver.unwrap(); + let track_remote = track_remote.unwrap(); + let peer = weak.upgrade().unwrap(); + Box::pin(async move { + let id = &track_remote.stream_id().await; + if let Some(res) = peer.remote_provided.read().await.get(id) { + info!("track for ({:?}) '{:?}'", res.id, res.label); + peer.inst + .event_handler + .resource_connected( + peer.clone(), + res, + TransportChannel::Track(track_remote), + ) + .await; + } else { + warn!("got unassociated track; stopping receiver"); + receiver.stop().await.unwrap(); + } + }) + }) + .await; + } + + { + let weak = Arc::<Peer>::downgrade(&peer); + peer.peer_connection .on_data_channel(box move |dc| { let peer = weak.upgrade().unwrap(); Box::pin(async move { |