cargo fmt

Author: cowlicks

benches/throughput.rs

@@ -6,7 +6,7 @@ use tokio::{
     net::TcpStream,
 };
 
-use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion, Throughput};
+use criterion::{BenchmarkId, Criterion, Throughput, criterion_group, criterion_main};
 criterion_group!(server_benches, bench_throughput);
 criterion_main!(server_benches);
 fn rt() -> tokio::runtime::Runtime {

examples/multi_stream.rs

@@ -1,4 +1,4 @@
-use async_udx::{UdxSocket, UDX_DATA_MTU};
+use async_udx::{UDX_DATA_MTU, UdxSocket};
 use std::time::Instant;
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
 

examples/rw.rs

@@ -4,7 +4,7 @@ use std::{future::Future, io};
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
 use tokio::task::JoinHandle;
 
-use async_udx::{UdxSocket, UdxStream, UDX_DATA_MTU};
+use async_udx::{UDX_DATA_MTU, UdxSocket, UdxStream};
 
 pub fn spawn<T>(name: impl ToString, future: T) -> JoinHandle<()>
 where

src/packet.rs

@@ -1,8 +1,8 @@
 use atomic_instant::AtomicInstant;
 use bytes::{BufMut, Bytes};
 use std::fmt::{self, Debug};
-use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
+use std::sync::atomic::{AtomicBool, Ordering};
 use std::{io, net::SocketAddr, sync::atomic::AtomicUsize};
 use udx_udp::Transmit;
 

src/stream.rs

@@ -548,9 +548,10 @@ impl UdxStreamInner {
         }
 
         if (self.inflight + UDX_MTU) <= self.cwnd
-            && let Some(waker) = self.write_waker.take() {
-                waker.wake();
-            }
+            && let Some(waker) = self.write_waker.take()
+        {
+            waker.wake();
+        }
 
         // reset rto, since things are moving forward.
         self.rto_timeout
@@ -669,9 +670,10 @@ impl UdxStreamInner {
 
             // packet is next in line, wake the read waker.
             if seq <= self.ack
-                && let Some(waker) = self.read_waker.take() {
-                    waker.wake();
-                }
+                && let Some(waker) = self.read_waker.take()
+            {
+                waker.wake();
+            }
             self.send_state_packet();
         }
 

tests/stream.rs

@@ -138,16 +138,20 @@ async fn test_halfopen_streams() -> io::Result<()> {
     bstr.write_all(b"BBB").await?;
 
     // b_stream message not seen as socket message to a bc a_stream is half open
-    assert!(tokio::time::timeout(Duration::from_millis(100), a.recv())
-        .await
-        .is_err());
+    assert!(
+        tokio::time::timeout(Duration::from_millis(100), a.recv())
+            .await
+            .is_err()
+    );
 
     let mut astr = a_half_str.connect(b.local_addr()?, bid)?;
     bstr.write_all(b"CCC").await?;
     // b_stream message not seen as socket message to a bc a_stream is open
-    assert!(tokio::time::timeout(Duration::from_millis(100), a.recv())
-        .await
-        .is_err());
+    assert!(
+        tokio::time::timeout(Duration::from_millis(100), a.recv())
+            .await
+            .is_err()
+    );
     let mut buf = vec![];
     astr.read_buf(&mut buf).await?;
     assert_eq!(&buf, b"AAABBBCCC");