Format

Author: ladvoc

livekit/src/room/mod.rs

@@ -353,7 +353,7 @@ pub struct RoomOptions {
     pub e2ee: Option<E2eeOptions>,
     pub rtc_config: RtcConfiguration,
     pub join_retries: u32,
-    pub sdk_options: RoomSdkOptions
+    pub sdk_options: RoomSdkOptions,
 }
 
 impl Default for RoomOptions {
@@ -372,7 +372,7 @@ impl Default for RoomOptions {
                 ice_transport_type: IceTransportsType::All,
             },
             join_retries: 3,
-            sdk_options: RoomSdkOptions::default()
+            sdk_options: RoomSdkOptions::default(),
         }
     }
 }
@@ -1175,7 +1175,7 @@ impl RoomSession {
             }),
             publish_tracks: self.local_participant.published_tracks_info(),
             data_channels: dcs,
-            datachannel_receive_states: session.data_channel_receive_states()
+            datachannel_receive_states: session.data_channel_receive_states(),
         };
 
         log::debug!("sending sync state {:?}", sync_state);

livekit/src/room/utils/mod.rs

@@ -1,8 +1,8 @@
 use std::collections::HashMap;
 
-pub(crate) mod tx_queue;
-pub(crate) mod ttl_map;
 pub mod take_cell;
+pub(crate) mod ttl_map;
+pub(crate) mod tx_queue;
 pub mod utf8_chunk;
 
 pub fn calculate_changed_attributes(

livekit/src/room/utils/ttl_map.rs

@@ -13,7 +13,10 @@
 // limitations under the License.
 
 use std::{
-    collections::HashMap, fmt::Debug, hash::Hash, time::{Duration, SystemTime}
+    collections::HashMap,
+    fmt::Debug,
+    hash::Hash,
+    time::{Duration, SystemTime},
 };
 
 /// Time to live (TTL) map

livekit/src/room/utils/tx_queue.rs

@@ -17,16 +17,13 @@ use std::collections::VecDeque;
 #[derive(Debug)]
 pub struct TxQueue<T> {
     inner: VecDeque<T>,
-    buffered_size: usize
+    buffered_size: usize,
 }
 
 impl<T: TxQueueItem> TxQueue<T> {
     /// Creates an empty queue.
     pub fn new() -> Self {
-        Self {
-            inner: VecDeque::new(),
-            buffered_size: 0
-        }
+        Self { inner: VecDeque::new(), buffered_size: 0 }
     }
 
     /// Number of elements in the queue.
@@ -113,4 +110,4 @@ mod tests {
         queue.trim(1);
         assert_eq!(queue.buffered_size(), 1);
     }
-}
+}