Fix formatting with cargo fmt

quinn-rs · Feb 12, 2021 · a016715 · a016715
1 parent 2687ef8
commit a016715
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 18 deletions.
diff --git a/quinn-proto/src/connection/streams/send.rs b/quinn-proto/src/connection/streams/send.rs
@@ -33,7 +33,10 @@ impl Send {
 
     /// Whether the stream has been reset
     pub(super) fn is_reset(&self) -> bool {
-        matches!(self.state, SendState::ResetSent { .. } | SendState::ResetRecvd { .. })
+        matches!(
+            self.state,
+            SendState::ResetSent { .. } | SendState::ResetRecvd { .. }
+        )
     }
 
     pub(super) fn finish(&mut self) -> Result<(), FinishError> {

diff --git a/quinn-proto/src/packet.rs b/quinn-proto/src/packet.rs
@@ -340,7 +340,10 @@ impl Header {
 
     /// Whether the packet is encrypted on the wire
     pub(crate) fn is_protected(&self) -> bool {
-        !matches!(*self, Header::Retry { .. } | Header::VersionNegotiate { .. })
+        !matches!(
+            *self,
+            Header::Retry { .. } | Header::VersionNegotiate { .. }
+        )
     }
 
     pub(crate) fn number(&self) -> Option<PacketNumber> {
@@ -387,7 +390,13 @@ impl Header {
     }
 
     pub(crate) fn is_0rtt(&self) -> bool {
-        matches!(*self, Header::Long { ty: LongType::ZeroRtt, .. })
+        matches!(
+            *self,
+            Header::Long {
+                ty: LongType::ZeroRtt,
+                ..
+            }
+        )
     }
 
     pub(crate) fn dst_cid(&self) -> &ConnectionId {

diff --git a/quinn-proto/src/tests/mod.rs b/quinn-proto/src/tests/mod.rs
@@ -815,11 +815,10 @@ fn instant_close_1() {
     assert_matches!(
         pair.server_conn_mut(server_ch).poll(),
         Some(Event::ConnectionLost {
-            reason:
-                ConnectionError::ConnectionClosed(ConnectionClose {
-                    error_code: TransportErrorCode::APPLICATION_ERROR,
-                    ..
-                }),
+            reason: ConnectionError::ConnectionClosed(ConnectionClose {
+                error_code: TransportErrorCode::APPLICATION_ERROR,
+                ..
+            }),
         })
     );
 }
@@ -847,11 +846,10 @@ fn instant_close_2() {
     assert_matches!(
         pair.server_conn_mut(server_ch).poll(),
         Some(Event::ConnectionLost {
-            reason:
-                ConnectionError::ConnectionClosed(ConnectionClose {
-                    error_code: TransportErrorCode::APPLICATION_ERROR,
-                    ..
-                }),
+            reason: ConnectionError::ConnectionClosed(ConnectionClose {
+                error_code: TransportErrorCode::APPLICATION_ERROR,
+                ..
+            }),
         })
     );
 }
@@ -913,11 +911,10 @@ fn concurrent_connections_full() {
     assert_matches!(
         pair.client_conn_mut(client_ch).poll(),
         Some(Event::ConnectionLost {
-            reason:
-                ConnectionError::ConnectionClosed(frame::ConnectionClose {
-                    error_code: TransportErrorCode::CONNECTION_REFUSED,
-                    ..
-                }),
+            reason: ConnectionError::ConnectionClosed(frame::ConnectionClose {
+                error_code: TransportErrorCode::CONNECTION_REFUSED,
+                ..
+            }),
         })
     );
     assert_eq!(pair.server.connections.len(), 0);