Committed by
Gerrit Code Review
Remove forEach() that introduces side-effect inherently
Change-Id: Idd9784d7a8a4064e31b02f65701bc599b2fb3dbf
Showing
1 changed file
with
5 additions
and
3 deletions
... | @@ -80,6 +80,7 @@ import java.util.Set; | ... | @@ -80,6 +80,7 @@ import java.util.Set; |
80 | import java.util.concurrent.CountDownLatch; | 80 | import java.util.concurrent.CountDownLatch; |
81 | import java.util.concurrent.TimeUnit; | 81 | import java.util.concurrent.TimeUnit; |
82 | import java.util.stream.Collectors; | 82 | import java.util.stream.Collectors; |
83 | +import java.util.stream.Stream; | ||
83 | 84 | ||
84 | import static com.google.common.base.Preconditions.checkNotNull; | 85 | import static com.google.common.base.Preconditions.checkNotNull; |
85 | import static org.onosproject.net.DeviceId.deviceId; | 86 | import static org.onosproject.net.DeviceId.deviceId; |
... | @@ -455,9 +456,10 @@ class ConfigProvider implements DeviceProvider, LinkProvider, HostProvider { | ... | @@ -455,9 +456,10 @@ class ConfigProvider implements DeviceProvider, LinkProvider, HostProvider { |
455 | .filter(cp -> !existing.contains(cp)) | 456 | .filter(cp -> !existing.contains(cp)) |
456 | .collect(Collectors.toSet()); | 457 | .collect(Collectors.toSet()); |
457 | 458 | ||
458 | - List<PortDescription> newPorts = Lists.newArrayList(); | 459 | + List<PortDescription> newPorts = Stream.concat( |
459 | - ports.forEach(p -> newPorts.add(description(p))); | 460 | + ports.stream().map(this::description), |
460 | - missing.forEach(cp -> newPorts.add(description(cp))); | 461 | + missing.stream().map(this::description) |
462 | + ).collect(Collectors.toList()); | ||
461 | deviceProviderService.updatePorts(device.id(), newPorts); | 463 | deviceProviderService.updatePorts(device.id(), newPorts); |
462 | } | 464 | } |
463 | 465 | ... | ... |
-
Please register or login to post a comment