mergeAll<T> static method

  1. @experimental
Cancelable<Iterable<T>> mergeAll<T>(
  1. Iterable<Cancelable<T>> cancelables
)

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();
      }
    },
  );
}