Add BrokerConnection.disconnected() method; update tests

1 files changed, 4 insertions, 0 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index cdf7a5e..92b2fd3 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -139,6 +139,10 @@ class BrokerConnection(object):
         """Return True iff socket is in intermediate connecting state."""
         return self.state is ConnectionStates.CONNECTING
 
+    def disconnected(self):
+        """Return True iff socket is closed"""
+        return self.state is ConnectionStates.DISCONNECTED
+
     def close(self, error=None):
         """Close socket and fail all in-flight-requests.