1
from twisted.internet.defer import DeferredList
4
def mergeDeferreds(deferreds, consumeErrors=True):
5
deferred = DeferredList(deferreds, consumeErrors=consumeErrors,
7
deferred.addCallback(lambda r: [x[1] for x in r])
8
deferred.addErrback(lambda f: f.value.subFailure)