diff --git a/protocol/protocol.go b/protocol/protocol.go
index cc8f6e77..5b403f43 100644
--- a/protocol/protocol.go
+++ b/protocol/protocol.go
@@ -262,9 +262,6 @@ func (c *Connection) readerLoop() {
 
 		case messageTypeRequest:
 			c.processRequest(hdr.msgID)
-			if c.mreader.err != nil || c.mwriter.err != nil {
-				c.close()
-			}
 
 		case messageTypeResponse:
 			data := c.mreader.readResponse()