(callbacks: Iterable[Callable], input, *a, **kw)
return d
Return a Deferred with the output of all successful calls to the given
    callbacks
Return a Deferred with the output of all successful calls to the given
    callbacks
Return a Deferred with the output of all successful calls to the given callbacks
def process_parallel(callbacks: Iterable[Callable], input, *a, **kw) -> Deferred:
    """Return a Deferred with the output of all successful calls to the given
    callbacks
    """
    dfds = [defer.succeed(input).addCallback(x, *a, **kw) for x in callbacks]
    d = DeferredList(dfds, fireOnOneErrback=True, consumeErrors=True)
    d.addCallbacks(lambda r: [x[1] for x in r], lambda f: f.value.subFailure)
    return d
def process_parallel ( callbacks : Iterable [ Callable ] , input , * a , * * kw ) -> Deferred : dfds = [ defer . succeed ( input ) . addCallback ( x , * a , * * kw ) for x in callbacks ] d = DeferredList ( dfds , fireOnOneErrback = True , consumeErrors = True ) d . addCallbacks ( lambda r : [ x [ 1 ] for x in r ] , lambda f : f . value . subFailure ) return d