Bump to odlparent 2.0.0

[controller.git] / opendaylight / md-sal / samples / toaster-consumer / src / main / java / org / opendaylight / controller / sample / kitchen / impl / KitchenServiceImpl.java

diff --git a/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java b/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java
index 0583368c20f97e7601dbbf0c0b37f720116636b2..1899afb7078b52ca1b936a9669899c475499d5aa 100644 (file)
--- a/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java
+++ b/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java
@@ -10,7 +10,6 @@ package org.opendaylight.controller.sample.kitchen.impl;
 
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableList.Builder;
-import com.google.common.util.concurrent.AsyncFunction;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.JdkFutureAdapters;
 import com.google.common.util.concurrent.ListenableFuture;
@@ -73,23 +72,22 @@ public class KitchenServiceImpl extends AbstractMXBean
 
         // Then transform the RpcResults into 1.
 
-        return Futures.transform(combinedFutures,
-            (AsyncFunction<List<RpcResult<Void>>, RpcResult<Void>>) results -> {
-                boolean atLeastOneSucceeded = false;
-                Builder<RpcError> errorList = ImmutableList.builder();
-                for (RpcResult<Void> result : results) {
-                    if (result.isSuccessful()) {
-                        atLeastOneSucceeded = true;
-                    }
-
-                    if (result.getErrors() != null) {
-                        errorList.addAll(result.getErrors());
-                    }
+        return Futures.transformAsync(combinedFutures, results -> {
+            boolean atLeastOneSucceeded = false;
+            Builder<RpcError> errorList = ImmutableList.builder();
+            for (RpcResult<Void> result : results) {
+                if (result.isSuccessful()) {
+                    atLeastOneSucceeded = true;
                 }
 
-                return Futures.immediateFuture(RpcResultBuilder.<Void>status(atLeastOneSucceeded)
-                        .withRpcErrors(errorList.build()).build());
-            });
+                if (result.getErrors() != null) {
+                    errorList.addAll(result.getErrors());
+                }
+            }
+
+            return Futures.immediateFuture(RpcResultBuilder.<Void>status(atLeastOneSucceeded)
+                    .withRpcErrors(errorList.build()).build());
+        });
     }
 
     private ListenableFuture<RpcResult<Void>> makeEggs(EggsType eggsType) {