Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSebastian Dröge <sebastian@centricular.com>2023-10-30 12:34:35 +0300
committerSebastian Dröge <sebastian@centricular.com>2023-10-30 12:34:35 +0300
commit855b03a9ead764fc093f80e59924c2adf2092710 (patch)
tree57ecbe127e2fd9212cf3b65f446587af2851d375 /net/webrtchttp
parent74c04d79c91fb58d4725c77876d6c6cde0559e66 (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.rs30
-rw-r--r--net/webrtchttp/src/whipsink/imp.rs5
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");