mergeAll<T> static method
Implementation
@experimental
static Cancelable<Iterable<T>> mergeAll<T>(
Iterable<Cancelable<T>> cancelables,
) {
final resultCompleter = Completer<Iterable<T>>();
Future.wait(cancelables).then((value) {
resultCompleter.complete(value);
}, onError: (Object error) {
_completeError(
completer: resultCompleter,
error: error,
);
});
return Cancelable(
completer: resultCompleter,
onCancel: () {
for (final cancelable in cancelables) {
cancelable.cancel();
}
},
);
}