mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-06-02 07:09:51 +00:00
Code Issues Projects Releases Wiki Activity

plugin: Fix some clippy issues

Browse source 
And minor reformat
This commit is contained in:
Thibault Saunier 2022-05-31 16:14:47 -04:00 committed by Mathieu Duponchelle
parent c53e5b8bb2
commit 287e76847a
3 changed files with 21 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
plugins/src/signaller/imp.rs
View file

@ -107,7 +107,9 @@ impl Signaller {
};
websocket_sender
.send(p::IncomingMessage::Register(p::RegisterMessage::Producer { meta, }))
.send(p::IncomingMessage::Register(p::RegisterMessage::Producer {
meta,
}))
.await?;
let element_clone = element.downgrade();

4
plugins/src/webrtcsink/imp.rs
View file

@ -2292,7 +2292,7 @@ impl WebRTCSink {
gst::MessageView::Error(err) => {
pipe.0.debug_to_dot_file_with_ts(
gst::DebugGraphDetails::all(),
"webrtcsink-discovery-error".to_string(),
"webrtcsink-discovery-error",
);
return Err(err.error().into());
}
@ -2301,7 +2301,7 @@ impl WebRTCSink {
pipe.0.debug_to_dot_file_with_ts(
gst::DebugGraphDetails::all(),
"webrtcsink-discovery-done".to_string(),
"webrtcsink-discovery-done",
);
if let Some(s) = caps.structure(0) {

20
signalling/src/handlers/mod.rs
View file

@ -342,7 +342,11 @@ impl Handler {
/// Register peer as a producer
#[instrument(level = "debug", skip(self))]
fn register_producer(&mut self, peer_id: &str, meta: Option<serde_json::Value>) -> Result<(), Error> {
fn register_producer(
&mut self,
peer_id: &str,
meta: Option<serde_json::Value>,
) -> Result<(), Error> {
if self.producers.contains_key(peer_id) {
Err(anyhow!("{} is already registered as a producer", peer_id))
} else {
@ -376,7 +380,11 @@ impl Handler {
/// Register peer as a consumer
#[instrument(level = "debug", skip(self))]
fn register_consumer(&mut self, peer_id: &str, meta: Option<serde_json::Value>) -> Result<(), Error> {
fn register_consumer(
&mut self,
peer_id: &str,
meta: Option<serde_json::Value>,
) -> Result<(), Error> {
if self.consumers.contains_key(peer_id) {
Err(anyhow!("{} is already registered as a consumer", peer_id))
} else {
@ -400,7 +408,11 @@ impl Handler {
/// Register peer as a listener
#[instrument(level = "debug", skip(self))]
fn register_listener(&mut self, peer_id: &str, meta: Option<serde_json::Value>) -> Result<(), Error> {
fn register_listener(
&mut self,
peer_id: &str,
meta: Option<serde_json::Value>,
) -> Result<(), Error> {
if !self.listeners.insert(peer_id.to_string()) {
Err(anyhow!("{} is already registered as a listener", peer_id))
} else {
@ -536,7 +548,7 @@ mod tests {
let mut handler = Handler::new(Box::pin(rx));
let message = p::IncomingMessage::Register(p::RegisterMessage::Producer {
meta: Some(json!( {"display-name": "foobar".to_string() }))
meta: Some(json!( {"display-name": "foobar".to_string() })),
});
tx.send(("producer".to_string(), Some(message)))