홍길동 / onos

Go to a project
Toggle navigation Toggle navigation pinning
Sho SHIMIZU
Committed by Gerrit Code Review
9aee1f56 1 parent f9879c5f

Refactor: Consolidate multiple map() invocations to single invocation 

Change-Id: I53bd6a80f34469eb23874f91dd52a895e0f5a2dc
Inline Side-by-side
Showing 1 changed file with 9 additions and 9 deletions
......@@ -325,15 +325,15 @@ public class IntentManager
(we can also try to update these individually)
*/
List<CompletableFuture<IntentData>> futures = operations.stream()
.map(CompletableFuture::completedFuture)
.map(x -> x.thenApply(IntentManager.this::createInitialPhase))
.map(x -> x.thenApplyAsync(IntentManager.this::process, workerExecutor))
.map(x -> x.thenApply(FinalIntentProcessPhase::data))
.map(x -> x.exceptionally(e -> {
//FIXME
log.warn("Future failed: {}", e);
return null;
}))
.map(x -> CompletableFuture.completedFuture(x)
.thenApply(IntentManager.this::createInitialPhase)
.thenApplyAsync(IntentManager.this::process, workerExecutor)
.thenApply(FinalIntentProcessPhase::data)
.exceptionally(e -> {
//FIXME
log.warn("Future failed: {}", e);
return null;
}))
.collect(Collectors.toList());
store.batchWrite(Tools.allOf(futures).join().stream()
.filter(Objects::nonNull)
......