Fix formatting

webrtc-rs · Nov 10, 2024 · 7b98732 · 7b98732
1 parent ab9813b
commit 7b98732
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 13 deletions.
diff --git a/interceptor/src/mock/mock_stream.rs b/interceptor/src/mock/mock_stream.rs
@@ -17,7 +17,7 @@ pub struct MockStream {
     rtcp_writer: Mutex<Option<Arc<dyn RTCPWriter + Send + Sync>>>,
     rtp_writer: Mutex<Option<Arc<dyn RTPWriter + Send + Sync>>>,
 
-    internal: Arc<MockStreamInternal>
+    internal: Arc<MockStreamInternal>,
 }
 
 struct MockStreamInternal {
@@ -65,7 +65,7 @@ impl MockStream {
 
                 rtcp_in_modified_rx: Mutex::new(rtcp_in_modified_rx),
                 rtp_in_modified_rx: Mutex::new(rtp_in_modified_rx),
-            })
+            }),
         });
 
         let rtcp_writer = interceptor

diff --git a/webrtc/src/data_channel/data_channel_test.rs b/webrtc/src/data_channel/data_channel_test.rs
@@ -206,7 +206,11 @@ async fn test_data_channel_send_before_signaling() -> Result<()> {
             d.on_message(Box::new(move |_: DataChannelMessage| {
                 let d3 = d2.clone();
                 Box::pin(async move {
-                    let result = d3.upgrade().unwrap().send(&Bytes::from(b"Pong".to_vec())).await;
+                    let result = d3
+                        .upgrade()
+                        .unwrap()
+                        .send(&Bytes::from(b"Pong".to_vec()))
+                        .await;
                     assert!(result.is_ok(), "Failed to send string on data channel");
                 })
             }));
@@ -263,7 +267,11 @@ async fn test_data_channel_send_after_connected() -> Result<()> {
                 let d3 = d2.clone();
 
                 Box::pin(async move {
-                    let result = d3.upgrade().unwrap().send(&Bytes::from(b"Pong".to_vec())).await;
+                    let result = d3
+                        .upgrade()
+                        .unwrap()
+                        .send(&Bytes::from(b"Pong".to_vec()))
+                        .await;
                     assert!(result.is_ok(), "Failed to send string on data channel");
                 })
             }));

diff --git a/webrtc/src/peer_connection/peer_connection_internal.rs b/webrtc/src/peer_connection/peer_connection_internal.rs
@@ -175,18 +175,17 @@ impl PeerConnectionInternal {
                     .await;
 
                     if let Some(dtls_transport) = dtls_transport.upgrade() {
-                            RTCPeerConnection::update_connection_state(
-                                &on_peer_connection_state_change_handler,
-                                &is_closed,
-                                &peer_connection_state,
-                                cs,
-                                dtls_transport.state(),
-                            )
-                                .await;
+                        RTCPeerConnection::update_connection_state(
+                            &on_peer_connection_state_change_handler,
+                            &is_closed,
+                            &peer_connection_state,
+                            cs,
+                            dtls_transport.state(),
+                        )
+                        .await;
                     } else {
                         log::warn!("on_ice_connection_state_change: dtls_transport unavailable");
                     }
-
                 })
             },
         ));