code: def asyncPipeUnion(context=None, _INPUT=None, conf=None, **kwargs):
      
      _input = yield _INPUT
      _OUTPUT = get_output(_input, **kwargs)
      returnValue(_OUTPUT)
docs: An operator that asynchronously merges multiple source together.
      Not loopable.
  
      Parameters
      ----------
      context : pipe2py.Context object
      _INPUT : asyncPipe like object (twisted Deferred iterable of items)
      conf : unused
  
      Keyword arguments
      -----------------
      _OTHER1 : asyncPipe like object
      _OTHER2 : etc.
  
      Returns
      -------
      _OUTPUT : twisted.internet.defer.Deferred generator of items