code: def _process_op_err(self, err=None):
          
          if self.is_connecting or self.is_closed or self.is_reconnecting:
              return
  
          if self.options["allow_reconnect"] and self.is_connected:
              self._status = Client.RECONNECTING
              yield self._attempt_reconnect()
          else:
              # Transition into CLOSED state
              self._status = Client.DISCONNECTED
              self._err = err
              yield self._close(Client.CLOSED)
docs: Process errors which occured while reading/parsing the protocol.
          It attempts to reconnect if `allow_reconnect' is enabled.