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.rs16
1 files changed, 8 insertions, 8 deletions
diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs
index 8c27234..023be1d 100644
--- a/client-native-lib/src/peer.rs
+++ b/client-native-lib/src/peer.rs
@@ -72,7 +72,7 @@ impl Peer {
}));
{
let weak = Arc::<Peer>::downgrade(&peer);
- peer.peer_connection.on_ice_candidate(box move |c| {
+ peer.peer_connection.on_ice_candidate(Box::new(move |c| {
if let Some(peer) = weak.upgrade() {
Box::pin(async move {
if let Some(c) = c {
@@ -82,21 +82,21 @@ impl Peer {
} else {
Box::pin(async move {})
}
- })
+ }))
}
{
let weak = Arc::<Peer>::downgrade(&peer);
- peer.peer_connection.on_negotiation_needed(box move || {
+ 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 move |track_remote, receiver| {
+ .on_track(Box::new(move |track_remote, receiver| {
let receiver = receiver.unwrap();
let track_remote = track_remote.unwrap();
let peer = weak.upgrade().unwrap();
@@ -117,12 +117,12 @@ impl Peer {
receiver.stop().await.unwrap();
}
})
- })
+ }))
}
{
let weak = Arc::<Peer>::downgrade(&peer);
- peer.peer_connection.on_data_channel(box move |dc| {
+ peer.peer_connection.on_data_channel(Box::new(move |dc| {
let peer = weak.upgrade().unwrap();
Box::pin(async move {
if let Some(res) = peer
@@ -145,7 +145,7 @@ impl Peer {
dc.close().await.unwrap();
}
})
- })
+ }))
}
peer
}