code: def asyncPipeLoop(context=None, _INPUT=None, conf=None, embed=None, **kwargs):
      
      cust_func = get_cust_func(context, conf, embed, parse_embed, **kwargs)
      opts.update({'cust_func': cust_func})
      splits = yield asyncGetSplits(_INPUT, conf, **cdicts(opts, kwargs))
      gathered = yield asyncStarMap(asyncParseResult, splits)
      _OUTPUT = utils.multiplex(gathered)
      returnValue(_OUTPUT)
docs: An operator that asynchronously loops over the input and performs the
      embedded submodule. Not loopable.
  
      Parameters
      ----------
      context : pipe2py.Context object
      _INPUT : asyncPipe like object (twisted Deferred iterable of items)
      embed : the submodule, i.e., asyncPipe*(context, _INPUT, conf)
          Most modules, with the exception of User inputs and Operators can be
          sub-modules.
  
      conf : {
          'assign_part': {'value': <all or first>},
          'assign_to': {'value': <assigned field name>},
          'emit_part': {'value': <all or first>},
          'mode': {'value': <assign or EMIT>},
          'with': {'value': <looped field name or blank>},
          'embed': {'value': {'conf': <module conf>}}
      }
  
      Returns
      -------
      _OUTPUT : twisted.internet.defer.Deferred generator of items