<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def asyncPipeUnion(context=None, _INPUT=None, conf=None, **kwargs):
 """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 """

    _input = yield _INPUT
    _OUTPUT = get_output(_input, **kwargs)
    returnValue(_OUTPUT)