Refactor: Inline method

Change-Id: Iafa70a7a728a3e701a2f62c4b9c015504bdcfabd

Refactor: Inline method
Change-Id: Iafa70a7a728a3e701a2f62c4b9c015504bdcfabd
Sho SHIMIZU · Thomas Vachuska
Commit c95ec3e0dc4883c65e82afbbf96444f4c6066c0d c95ec3e0 1 parent 594fb2ad
Showing 1 changed file with 2 additions and 6 deletions
core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java
--- a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java
View file @c95ec3e
+++ b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java
View file @c95ec3e
@@ -293,11 +293,6 @@ public class IntentManager
         }
     }
 
-     private CompletableFuture<FinalIntentProcessPhase> submitIntentData(IntentData data) {
-         IntentProcessPhase initial = createInitialPhase(data);
-         return CompletableFuture.supplyAsync(() -> process(initial), workerExecutor);
-     }
- 
     private IntentProcessPhase createInitialPhase(IntentData data) {
         IntentData current = store.getIntentData(data.key());
         return newInitialPhase(processor, data, current);
@@ -330,7 +325,8 @@ public class IntentManager
                     (we can also try to update these individually)
                  */
                     List<CompletableFuture<IntentData>> futures = operations.stream()
-                             .map(IntentManager.this::submitIntentData)
+                             .map(x -> createInitialPhase(x))
+                             .map(x -> CompletableFuture.supplyAsync(() -> process(x), workerExecutor))
                             .map(x -> x.thenApply(FinalIntentProcessPhase::data))
                             .map(x -> x.exceptionally(e -> {
                                 //FIXME