code: async def _sasl_end(self):
          
          if self._sasl_timer:
              self._sasl_timer.cancel()
              self._sasl_timer = None
          await self._capability_negotiated('sasl')
docs: Finalize SASL authentication.