Improve wakeup close

Author: dpkp

kafka/client_async.py

@@ -251,7 +251,7 @@ def _close_wakeup_socketpair(self):
         if self._wake_r is not None:
             try:
                 self._selector.unregister(self._wake_r)
-            except KeyError:
+            except (KeyError, ValueError, TypeError):
                 pass
             self._wake_r.close()
         if self._wake_w is not None:
@@ -432,8 +432,8 @@ def connected(self, node_id):
     def _close(self):
         if not self._closed:
             self._closed = True
-            self._selector.close()
             self._close_wakeup_socketpair()
+            self._selector.close()
 
     def close(self, node_id=None):
         """Close one or all broker connections.