code: def create(self, jid, node=None):
          
  
          create = pubsub_xso.Create()
          create.node = node
  
          iq = aioxmpp.stanza.IQ(
              type_=aioxmpp.structs.IQType.SET,
              to=jid,
              payload=pubsub_xso.Request(create)
          )
  
          response = yield from self.client.send(iq)
  
          if response is not None and response.payload.node is not None:
              return response.payload.node
  
          return node
docs: Create a new node at a service.
  
          :param jid: Address of the PubSub service.
          :type jid: :class:`aioxmpp.JID`
          :param node: Name of the PubSub node to create.
          :type node: :class:`str` or :data:`None`
          :raises aioxmpp.errors.XMPPError: as returned by the service
          :return: The name of the created node.
          :rtype: :class:`str`
  
          If `node` is :data:`None`, an instant node is created (see :xep:`60`).
          The server may not support or allow the creation of instant nodes.
  
          Return the actual `node` identifier.