diff --git a/crates/networking/p2p/rlpx/connection.rs b/crates/networking/p2p/rlpx/connection.rs
index 900098c5a4..59fd467902 100644
--- a/crates/networking/p2p/rlpx/connection.rs
+++ b/crates/networking/p2p/rlpx/connection.rs
@@ -238,24 +238,31 @@ impl<S: AsyncWrite + AsyncRead + std::marker::Unpin> RLPxConnection<S> {
         self.send(hello_msg).await?;
 
         // Receive Hello message
-        if let Message::Hello(hello_message) = self.receive().await? {
-            self.capabilities = hello_message.capabilities;
-
-            // Check if we have any capability in common
-            for cap in self.capabilities.clone() {
-                if SUPPORTED_CAPABILITIES.contains(&cap) {
-                    return Ok(());
+        match self.receive().await? {
+            Message::Hello(hello_message) => {
+                self.capabilities = hello_message.capabilities;
+
+                // Check if we have any capability in common
+                for cap in self.capabilities.clone() {
+                    if SUPPORTED_CAPABILITIES.contains(&cap) {
+                        return Ok(());
+                    }
                 }
+                // Return error if not
+                Err(RLPxError::HandshakeError(
+                    "No matching capabilities".to_string(),
+                ))
+            }
+            Message::Disconnect(disconnect) => Err(RLPxError::HandshakeError(format!(
+                "Peer disconnected due to: {}",
+                disconnect.reason()
+            ))),
+            _ => {
+                // Fail if it is not a hello message
+                Err(RLPxError::HandshakeError(
+                    "Expected Hello message".to_string(),
+                ))
             }
-            // Return error if not
-            Err(RLPxError::HandshakeError(
-                "No matching capabilities".to_string(),
-            ))
-        } else {
-            // Fail if it is not a hello message
-            Err(RLPxError::HandshakeError(
-                "Expected Hello message".to_string(),
-            ))
         }
     }
 
@@ -479,7 +486,13 @@ impl<S: AsyncWrite + AsyncRead + std::marker::Unpin> RLPxConnection<S> {
                     debug!("Received Status");
                     backend::validate_status(msg_data, &self.storage)?
                 }
-                _msg => {
+                Message::Disconnect(disconnect) => {
+                    return Err(RLPxError::HandshakeError(format!(
+                        "Peer disconnected due to: {}",
+                        disconnect.reason()
+                    )))
+                }
+                _ => {
                     return Err(RLPxError::HandshakeError(
                         "Expected a Status message".to_string(),
                     ))