Cargo fmt

Author: sax

src/data_channel/mod.rs

@@ -26,8 +26,8 @@ use data_channel_state::RTCDataChannelState;
 use crate::api::setting_engine::SettingEngine;
 use crate::error::{Error, OnErrorHdlrFn, Result};
 use crate::sctp_transport::RTCSctpTransport;
-use crate::stats::{StatsReportType, DataChannelStats};
 use crate::stats::stats_collector::StatsCollector;
+use crate::stats::{DataChannelStats, StatsReportType};
 
 /// message size limit for Chromium
 const DATA_CHANNEL_BUFFER_SIZE: u16 = u16::MAX;

src/peer_connection/mod.rs

@@ -1986,7 +1986,10 @@ impl RTCPeerConnection {
     }
 
     pub async fn get_stats(&self) -> StatsReport {
-        self.internal.get_stats(self.get_stats_id().to_owned()).await.into()
+        self.internal
+            .get_stats(self.get_stats_id().to_owned())
+            .await
+            .into()
     }
     // GetStats return data providing statistics about the overall connection
     /*TODO: func (pc *PeerConnection) GetStats() StatsReport {

src/peer_connection/peer_connection_internal.rs

@@ -1326,7 +1326,8 @@ impl PeerConnectionInternal {
         tokio::join!(
             self.ice_gatherer.collect_stats(&collector, wg.worker()),
             self.ice_transport.collect_stats(&collector, wg.worker()),
-            self.sctp_transport.collect_stats(&collector, wg.worker(), stats_id),
+            self.sctp_transport
+                .collect_stats(&collector, wg.worker(), stats_id),
             self.dtls_transport.collect_stats(&collector, wg.worker()),
             self.media_engine.collect_stats(&collector, wg.worker()),
         );

src/sctp_transport/mod.rs

@@ -16,8 +16,8 @@ use crate::dtls_transport::*;
 use crate::error::*;
 use crate::sctp_transport::sctp_transport_capabilities::SCTPTransportCapabilities;
 use crate::stats::stats_collector::StatsCollector;
-use crate::stats::{ICETransportStats, PeerConnectionStats};
 use crate::stats::StatsReportType::{PeerConnection, SCTPTransport};
+use crate::stats::{ICETransportStats, PeerConnectionStats};
 
 use data::message::message_channel_open::ChannelType;
 use sctp::association::Association;
@@ -364,7 +364,11 @@ impl RTCSctpTransport {
         }
 
         let mut reports = vec![];
-        reports.push(PeerConnection(PeerConnectionStats::new(self, peer_connection_id, data_channels_closed)));
+        reports.push(PeerConnection(PeerConnectionStats::new(
+            self,
+            peer_connection_id,
+            data_channels_closed,
+        )));
 
         // conn
         if let Some(_net_conn) = dtls_transport.conn().await {