mergeObservable method

Stream<List<DistanceDocSnapshot>> mergeObservable(
  1. Iterable<Stream<List<DistanceDocSnapshot>>> queries
)

Implementation

Stream<List<DistanceDocSnapshot>> mergeObservable(
    Iterable<Stream<List<DistanceDocSnapshot>>> queries) {
  Stream<List<DistanceDocSnapshot>> mergedObservable = Rx.combineLatest(
      queries, (List<List<DistanceDocSnapshot>> originalList) {
    final reducedList = <DistanceDocSnapshot>[];
    originalList.forEach((t) {
      reducedList.addAll(t);
    });
    return reducedList;
  });
  return mergedObservable;
}