demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/danieldemus/openhab-addons synced 2026-07-29 12:34:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix the wrong use of Stream that's causing #19854 (#19855)

Browse Source 
Signed-off-by: Ravi Nadahar <nadahar@rediffmail.com>
This commit is contained in:
Nadahar
2025-12-21 23:23:34 +01:00
committed by GitHub
parent 9b42a1d51d
commit 2edcefc8ef
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bundles/org.openhab.persistence.rrd4j/src/main/java/org/openhab/persistence/rrd4j/internal/console/RRD4jCommandExtension.java
+4 -6
View File
@@ -17,10 +17,9 @@ import java.nio.file.Path;
import java.util.Collections; import java.util.Collections;
import java.util.Comparator; import java.util.Comparator;
import java.util.List; import java.util.List;
import java.util.Map.Entry; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.eclipse.jdt.annotation.NonNullByDefault; import org.eclipse.jdt.annotation.NonNullByDefault;
import org.eclipse.jdt.annotation.Nullable; import org.eclipse.jdt.annotation.Nullable;
@@ -114,8 +113,7 @@ public class RRD4jCommandExtension extends AbstractConsoleCommandExtension imple
PersistenceServiceConfiguration config = persistenceServiceConfigurationRegistry PersistenceServiceConfiguration config = persistenceServiceConfigurationRegistry
.get(RRD4jPersistenceService.SERVICE_ID); .get(RRD4jPersistenceService.SERVICE_ID);
Stream<Entry<String, String>> aliases = config != null ? config.getAliases().entrySet().stream() Map<String, String> aliases = config == null ? Map.of() : Map.copyOf(config.getAliases());
: Stream.empty();
console.println((checkOnly ? "Checking" : "Cleaning") + " RRD files..."); console.println((checkOnly ? "Checking" : "Cleaning") + " RRD files...");
int nb = 0; int nb = 0;
@@ -128,8 +126,8 @@ public class RRD4jCommandExtension extends AbstractConsoleCommandExtension imple
boolean itemFound; boolean itemFound;
try { try {
// Map alias back to item // Map alias back to item
String item = Objects.requireNonNull( String item = Objects.requireNonNull(aliases.entrySet().stream()
aliases.filter(e -> name.equals(e.getValue())).findAny().map(e -> e.getKey()).orElse(name)); .filter(e -> name.equals(e.getValue())).findAny().map(e -> e.getKey()).orElse(name));
itemRegistry.getItem(item); itemRegistry.getItem(item);
itemFound = true; itemFound = true;
} catch (ItemNotFoundException e) { } catch (ItemNotFoundException e) {