diff --git a/cassandra/io/libevreactor.py b/cassandra/io/libevreactor.py
index 45265089..6b7376e3 100644
--- a/cassandra/io/libevreactor.py
+++ b/cassandra/io/libevreactor.py
@@ -259,6 +259,9 @@ class LibevConnection(Connection):
                     else:
                         self._total_reqd_bytes = body_len + 8
                         break
+        else:
+            log.debug("Connection %s closed by server", self)
+            self.close()
 
     def handle_pushed(self, response):
         log.debug("Message pushed from server: %r", response)