code: def _process_outgoing(self, xmlstream, token):
          
  
          self._send_stanza(xmlstream, token)
          # try to send a bulk
          while True:
              try:
                  token = self._active_queue.get_nowait()
              except asyncio.QueueEmpty:
                  break
              self._send_stanza(xmlstream, token)
  
          if self._sm_enabled:
              self._logger.debug("sending SM req")
              xmlstream.send_xso(nonza.SMRequest())
docs: Process the current outgoing stanza `token` and also any other outgoing
          stanza which is currently in the active queue. After all stanzas have
          been processed, use :meth:`_send_ping` to allow an opportunistic ping
          to be sent.