diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2023-10-30 12:34:35 +0300 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2023-10-30 12:34:35 +0300 |
commit | 855b03a9ead764fc093f80e59924c2adf2092710 (patch) | |
tree | 57ecbe127e2fd9212cf3b65f446587af2851d375 /net/webrtchttp | |
parent | 74c04d79c91fb58d4725c77876d6c6cde0559e66 (diff) |
Use let-else instead of match for weak reference upgrades
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1375>
Diffstat (limited to 'net/webrtchttp')
-rw-r--r-- | net/webrtchttp/src/whepsrc/imp.rs | 30 | ||||
-rw-r--r-- | net/webrtchttp/src/whipsink/imp.rs | 5 |
2 files changed, 14 insertions, 21 deletions
diff --git a/net/webrtchttp/src/whepsrc/imp.rs b/net/webrtchttp/src/whepsrc/imp.rs index a0b56f119..dd423a6f6 100644 --- a/net/webrtchttp/src/whepsrc/imp.rs +++ b/net/webrtchttp/src/whepsrc/imp.rs @@ -426,9 +426,8 @@ impl WhepSrc { let self_weak = self.downgrade(); self.webrtcbin .connect_notify(Some("ice-gathering-state"), move |webrtcbin, _pspec| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return, + let Some(self_) = self_weak.upgrade() else { + return; }; let state = webrtcbin.property::<WebRTCICEGatheringState>("ice-gathering-state"); @@ -458,9 +457,8 @@ impl WhepSrc { let self_weak = self.downgrade(); self.webrtcbin .connect_notify(Some("ice-connection-state"), move |webrtcbin, _pspec| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return, + let Some(self_) = self_weak.upgrade() else { + return; }; let state = webrtcbin.property::<WebRTCICEConnectionState>("ice-connection-state"); @@ -489,9 +487,8 @@ impl WhepSrc { let self_weak = self.downgrade(); self.webrtcbin .connect_notify(Some("connection-state"), move |webrtcbin, _pspec| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return, + let Some(self_) = self_weak.upgrade() else { + return; }; let state = webrtcbin.property::<WebRTCPeerConnectionState>("connection-state"); @@ -520,9 +517,8 @@ impl WhepSrc { let self_weak = self.downgrade(); self.webrtcbin.connect_pad_added(move |_, pad| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return, + let Some(self_) = self_weak.upgrade() else { + return; }; gst::debug!( @@ -547,9 +543,8 @@ impl WhepSrc { let self_weak = self.downgrade(); self.webrtcbin.connect("on-negotiation-needed", false, { move |_| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return None, + let Some(self_) = self_weak.upgrade() else { + return None; }; let settings = self_.settings.lock().unwrap(); @@ -780,9 +775,8 @@ impl WhepSrc { fn generate_offer(&self) { let self_weak = self.downgrade(); let promise = gst::Promise::with_change_func(move |reply| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return, + let Some(self_) = self_weak.upgrade() else { + return; }; let reply = match reply { diff --git a/net/webrtchttp/src/whipsink/imp.rs b/net/webrtchttp/src/whipsink/imp.rs index 0d1d3649f..619b0214e 100644 --- a/net/webrtchttp/src/whipsink/imp.rs +++ b/net/webrtchttp/src/whipsink/imp.rs @@ -357,9 +357,8 @@ impl ObjectImpl for WhipSink { let self_weak = self.downgrade(); self.webrtcbin .connect_notify(Some("ice-gathering-state"), move |webrtcbin, _pspec| { - let self_ = match self_weak.upgrade() { - Some(self_) => self_, - None => return, + let Some(self_) = self_weak.upgrade() else { + return; }; let state = webrtcbin.property::<WebRTCICEGatheringState>("ice-gathering-state"); |