diff --git a/crates/call/src/call.rs b/crates/call/src/call.rs index 1ad7dbc1fc..3fc76b964d 100644 --- a/crates/call/src/call.rs +++ b/crates/call/src/call.rs @@ -1,6 +1,6 @@ +pub mod call_settings; pub mod participant; pub mod room; -pub mod call_settings; use std::sync::Arc; diff --git a/crates/call/src/call_settings.rs b/crates/call/src/call_settings.rs index 356ae3ef19..2808a99617 100644 --- a/crates/call/src/call_settings.rs +++ b/crates/call/src/call_settings.rs @@ -1,5 +1,5 @@ use schemars::JsonSchema; -use serde_derive::{Serialize, Deserialize}; +use serde_derive::{Deserialize, Serialize}; use settings::Setting; #[derive(Deserialize, Debug)] diff --git a/crates/call/src/room.rs b/crates/call/src/room.rs index d57d4f711b..08ac8befc4 100644 --- a/crates/call/src/room.rs +++ b/crates/call/src/room.rs @@ -20,7 +20,7 @@ use live_kit_client::{ }; use postage::stream::Stream; use project::Project; -use std::{future::Future, mem, pin::Pin, sync::Arc, time::Duration, panic::Location}; +use std::{future::Future, mem, panic::Location, pin::Pin, sync::Arc, time::Duration}; use util::{post_inc, ResultExt, TryFutureExt}; pub const RECONNECT_TIMEOUT: Duration = Duration::from_secs(30); diff --git a/crates/live_kit_client/src/prod.rs b/crates/live_kit_client/src/prod.rs index 2b5148e4a3..d8d0277440 100644 --- a/crates/live_kit_client/src/prod.rs +++ b/crates/live_kit_client/src/prod.rs @@ -376,12 +376,19 @@ impl Room { rx } - fn did_subscribe_to_remote_audio_track(&self, track: RemoteAudioTrack, publication: RemoteTrackPublication) { + fn did_subscribe_to_remote_audio_track( + &self, + track: RemoteAudioTrack, + publication: RemoteTrackPublication, + ) { let track = Arc::new(track); let publication = Arc::new(publication); self.remote_audio_track_subscribers.lock().retain(|tx| { - tx.unbounded_send(RemoteAudioTrackUpdate::Subscribed(track.clone(), publication.clone())) - .is_ok() + tx.unbounded_send(RemoteAudioTrackUpdate::Subscribed( + track.clone(), + publication.clone(), + )) + .is_ok() }); } diff --git a/crates/live_kit_client/src/test.rs b/crates/live_kit_client/src/test.rs index 3b91e0ef89..704760bab7 100644 --- a/crates/live_kit_client/src/test.rs +++ b/crates/live_kit_client/src/test.rs @@ -227,7 +227,10 @@ impl TestServer { .lock() .audio_track_updates .0 - .try_broadcast(RemoteAudioTrackUpdate::Subscribed(track.clone(), publication.clone())) + .try_broadcast(RemoteAudioTrackUpdate::Subscribed( + track.clone(), + publication.clone(), + )) .unwrap(); } }