code: def asyncPipeFetch(context=None, _INPUT=None, conf=None, **kwargs):
      
      splits = yield asyncGetSplits(_INPUT, conf['URL'], **cdicts(opts, kwargs))
      items = yield asyncStarMap(asyncParseResult, splits)
      _OUTPUT = utils.multiplex(items)
      returnValue(_OUTPUT)
docs: A source that asynchronously fetches and parses one or more feeds to
      return the feed entries. Loopable.
  
      Parameters
      ----------
      context : pipe2py.Context object
      _INPUT : asyncPipe like object (twisted Deferred iterable of items)
      conf : {
          'URL': [
              {'type': 'url', 'value': <url1>},
              {'type': 'url', 'value': <url2>},
              {'type': 'url', 'value': <url3>},
          ]
      }
  
      Returns
      -------
      _OUTPUT : twisted.internet.defer.Deferred generator of items