'SASL authentication succeeded. Restart the stream.'

def _handle_success(self, stanza):

    try:
        final = self.mech.process(stanza['value'])
    except sasl.SASLMutualAuthFailed:
        log.error(('Mutual    authentication    failed!    ' + 'A    security    breach    is    possible.'))
        self.attempted_mechs.add(self.mech.name)
        self.xmpp.disconnect()
    else:
        self.attempted_mechs = set()
        self.xmpp.authenticated = True
        self.xmpp.features.add('mechanisms')
        self.xmpp.event('auth_success', stanza, direct=True)
        raise RestartStream()
