code: def pipe_loop(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 = get_splits(_INPUT, conf, **cdicts(opts, kwargs))
      gathered = starmap(parse_result, splits)
      _OUTPUT = utils.multiplex(gathered)
      return _OUTPUT
docs: An operator that loops over the input and performs the embedded
      submodule. Not loopable.
  
      Parameters
      ----------
      context : pipe2py.Context object
      _INPUT : pipe2py.modules pipe like object (iterable of items)
      embed : the submodule, i.e., pipe_*(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 : generator of items