check: clippy

binbat · Mar 2, 2024 · 5b53180 · 5b53180
1 parent f46081c
commit 5b53180
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/src/forward/forward_internal.rs b/src/forward/forward_internal.rs
@@ -224,10 +224,9 @@ impl PeerForwardInternal {
     pub(crate) async fn set_publish(&self, peer: Arc<RTCPeerConnection>) -> Result<()> {
         let mut publish = self.publish.write().await;
         if publish.is_some() {
-            return Err(AppError::ResourceAlreadyExists(
-                "A connection has already been established".to_string(),
-            )
-            .into());
+            return Err(AppError::resource_already_exists(
+                "A connection has already been established",
+            ));
         }
         let publish_peer = PublishRTCPeerConnection::new(
             self.id.clone(),

diff --git a/src/forward/subscribe.rs b/src/forward/subscribe.rs
@@ -249,7 +249,7 @@ impl SubscribeRTCPeerConnection {
 
     pub(crate) fn select_kind_rid(&self, kind: RTPCodecType, rid: String) -> Result<()> {
         if let Err(err) = self.select_layer_sender.send((kind, rid)) {
-            Err(AppError::Throw(format!("select layer send err: {}", err)))
+            Err(AppError::throw(format!("select layer send err: {}", err)))
         } else {
             Ok(())
         }