code: def parse_cluster_pubsub_numsub(res, **options):
      
      aggregate = options.get('aggregate', True)
      if not aggregate:
          return res
  
      numsub_d = dict()
      for _, numsub_tups in res.items():
          for channel, numsubbed in numsub_tups:
              try:
                  numsub_d[channel] += numsubbed
              except KeyError:
                  numsub_d[channel] = numsubbed
  
      ret_numsub = []
      for channel, numsub in numsub_d.items():
          ret_numsub.append((channel, numsub))
      return ret_numsub
docs: Result callback, handles different return types
      switchable by the `aggregate` flag.