code: def parse_cluster_pubsub_channels(res, **options):
      
      aggregate = options.get('aggregate', True)
      if not aggregate:
          return res
      return merge_result(res)
docs: Result callback, handles different return types
      switchable by the `aggregate` flag.