code: async def _capability_negotiated(self, capab):
          
          self._capabilities_negotiating.discard(capab)
  
          if not self._capabilities_requested and not self._capabilities_negotiating:
              await self.rawmsg('CAP', 'END')
docs: Mark capability as negotiated, and end negotiation if we're done.