diff --git a/crates/livekit-webrtc/src/data_channel.rs b/crates/livekit-webrtc/src/data_channel.rs index e87f6ea..7819c17 100644 --- a/crates/livekit-webrtc/src/data_channel.rs +++ b/crates/livekit-webrtc/src/data_channel.rs @@ -1,7 +1,7 @@ -use std::fmt::{Debug, Formatter}; use cxx::UniquePtr; use libwebrtc_sys::data_channel as sys_dc; use log::trace; +use std::fmt::{Debug, Formatter}; use std::sync::{Arc, Mutex}; pub use sys_dc::ffi::Priority; diff --git a/crates/livekit-webrtc/src/peer_connection.rs b/crates/livekit-webrtc/src/peer_connection.rs index 4329e2a..f03f123 100644 --- a/crates/livekit-webrtc/src/peer_connection.rs +++ b/crates/livekit-webrtc/src/peer_connection.rs @@ -1,9 +1,9 @@ -use std::fmt::{Debug, Formatter}; use cxx::UniquePtr; use libwebrtc_sys::data_channel as sys_dc; use libwebrtc_sys::jsep as sys_jsep; use libwebrtc_sys::peer_connection as sys_pc; use log::trace; +use std::fmt::{Debug, Formatter}; use std::sync::{Arc, Mutex}; use thiserror::Error; use tokio::sync::{mpsc, oneshot}; @@ -672,7 +672,9 @@ mod tests { let (data_tx, mut data_rx) = mpsc::channel::(1); let mut alice_dc = alice_dc_rx.recv().await.unwrap(); alice_dc.on_message(Box::new(move |data, is_binary| { - data_tx.blocking_send(String::from_utf8_lossy(data).to_string()).unwrap(); + data_tx + .blocking_send(String::from_utf8_lossy(data).to_string()) + .unwrap(); })); assert!(bob_dc.send(b"This is a test", true));