nats/aio/client.py
def _process_err(self, err_msg):
        """
        Processes the raw error message sent by the server
        and close connection with current server.
        """
        if STALE_CONNECTION in err_msg:
            yield from self._process_op_err(ErrStaleConnection)
            return

        if AUTHORIZATION_VIOLATION in err_msg:
            self._err = ErrAuthorization
        else:
            m = b'nats: ' + err_msg[0]
            self._err = NatsError(m.decode())

        do_cbs = False
        if not self.is_connecting:
            do_cbs = True

        # FIXME: Some errors such as 'Invalid Subscription'
        # do not cause the server to close the connection.
        # For now we handle similar as other clients and close.
        self._loop.create_task(self._close(Client.CLOSED, do_cbs))
def _process_err(self, err_msg):
        if STALE_CONNECTION in err_msg:
            yield from self._process_op_err(ErrStaleConnection)
            return

        if AUTHORIZATION_VIOLATION in err_msg:
            self._err = ErrAuthorization
        else:
            m = b'nats: ' + err_msg[0]
            self._err = NatsError(m.decode())

        do_cbs = False
        if not self.is_connecting:
            do_cbs = True

        # FIXME: Some errors such as 'Invalid Subscription'
        # do not cause the server to close the connection.
        # For now we handle similar as other clients and close.
        self._loop.create_task(self._close(Client.CLOSED, do_cbs))
def _process_err ( self , err_msg ) : if STALE_CONNECTION in err_msg : yield from self . _process_op_err ( ErrStaleConnection ) return if AUTHORIZATION_VIOLATION in err_msg : self . _err = ErrAuthorization else : m = b'nats: ' + err_msg [ 0 ] self . _err = NatsError ( m . decode ( ) ) do_cbs = False if not self . is_connecting : do_cbs = True # FIXME: Some errors such as 'Invalid Subscription' # do not cause the server to close the connection. # For now we handle similar as other clients and close. self . _loop . create_task ( self . _close ( Client . CLOSED , do_cbs ) )
Processes the raw error message sent by the server
        and close connection with current server.
Processes the raw error message sent by the server and close connection with current server .