diff --git a/cassandra/io/asyncorereactor.py b/cassandra/io/asyncorereactor.py index 02b78d53..282621ed 100644 --- a/cassandra/io/asyncorereactor.py +++ b/cassandra/io/asyncorereactor.py @@ -293,8 +293,6 @@ class AsyncoreConnection(Connection, asyncore.dispatcher): if not self._callbacks: self._readable = False - else: - self.close() def handle_pushed(self, response): log.debug("Message pushed from server: %r", response)