flatMap -> concatMap

hawkular · Mar 31, 2018 · 5897636 · 5897636
1 parent 41ef4ca
commit 5897636
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rics-core-service/src/main/java/org/hawkular/metrics/core/service/MetricsServiceImpl.java b/...rics-core-service/src/main/java/org/hawkular/metrics/core/service/MetricsServiceImpl.java
@@ -777,7 +777,7 @@ public Completable verifyAndCreateTempTables(ZonedDateTime startTime, ZonedDateT
     public Completable compressBlock(long jobStartTimeSlice, int pageSize, int maxConcurrency) {
         return Completable.fromObservable(
                 Observable.from(dataAccess.findExpiredTables(jobStartTimeSlice))
-                        .flatMap(startTimeSlice ->
+                        .concatMap(startTimeSlice ->
                                 dataAccess.findAllDataFromBucket(startTimeSlice, pageSize, maxConcurrency)
                                         .switchIfEmpty(Observable.empty())
                                         .flatMap(rows -> rows