code: def pipe_fetchdata(context=None, _INPUT=None, conf=None, **kwargs):
      funcs = get_splits(None, conf, **cdicts(opts, kwargs))
      parsed = get_parsed(_INPUT, funcs[0])
      results = starmap(parse_result, parsed)
      items = imap(utils.gen_items, results)
      _OUTPUT = utils.multiplex(items)
      return _OUTPUT