IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix bug in service loader

Browse Source
This commit is contained in:
Jonathan Shook 2021-12-21 16:43:59 -06:00
parent e60dfeea67
commit a23ffeee6b
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
nb-api/src/main/java/io/nosqlbench/nb/api/spi/SimpleServiceLoader.java
View File

@ -43,8 +43,17 @@ public class SimpleServiceLoader<T> {
public Optional<T> get(String implName) {
List<Component<? extends T>> namedProviders = getNamedProviders();
ServiceLoader.Provider<? extends T> providers = namedProviders.stream().filter(n -> n.selector.equals(implName)).findFirst().get().provider;
return Optional.ofNullable(providers == null ? null : providers.get());
if (namedProviders==null) {
return Optional.empty();
}
List<Component<? extends T>> components = namedProviders.stream().filter(n -> n.selector.equals(implName)).toList();
if (components.size()>1) {
throw new RuntimeException("Found multiple components matching '" + implName +"',");
}
if (components.size()==0) {
return Optional.empty();
}
return Optional.of(components.get(0).provider.get());
}
public T getOrThrow(String implName) {