|
1 | 1 | package org.dataloader; |
2 | 2 |
|
3 | 3 | import org.dataloader.annotations.PublicApi; |
| 4 | +import org.dataloader.impl.Assertions; |
4 | 5 | import org.dataloader.instrumentation.ChainedDataLoaderInstrumentation; |
5 | 6 | import org.dataloader.instrumentation.DataLoaderInstrumentation; |
6 | 7 | import org.dataloader.instrumentation.DataLoaderInstrumentationHelper; |
|
14 | 15 | import java.util.LinkedHashMap; |
15 | 16 | import java.util.List; |
16 | 17 | import java.util.Map; |
| 18 | +import java.util.Objects; |
17 | 19 | import java.util.Set; |
18 | 20 | import java.util.concurrent.ConcurrentHashMap; |
19 | 21 | import java.util.function.Function; |
@@ -141,8 +143,7 @@ private static DataLoaderOptions setInInstrumentation(DataLoaderOptions options, |
141 | 143 | * @return this registry |
142 | 144 | */ |
143 | 145 | public DataLoaderRegistry register(DataLoader<?, ?> dataLoader) { |
144 | | - String name = dataLoader.getName(); |
145 | | - assertState(name != null, () -> "The DataLoader must have a non null name"); |
| 146 | + String name = Assertions.nonNull(dataLoader.getName(), () -> "The DataLoader must have a non null name"); |
146 | 147 | dataLoaders.put(name, nameAndInstrumentDL(name, instrumentation, dataLoader)); |
147 | 148 | return this; |
148 | 149 | } |
@@ -176,7 +177,7 @@ public DataLoaderRegistry register(String key, DataLoader<?, ?> dataLoader) { |
176 | 177 | */ |
177 | 178 | public <K, V> DataLoader<K, V> registerAndGet(String key, DataLoader<?, ?> dataLoader) { |
178 | 179 | dataLoaders.put(key, nameAndInstrumentDL(key, instrumentation, dataLoader)); |
179 | | - return getDataLoader(key); |
| 180 | + return Objects.requireNonNull(getDataLoader(key)); |
180 | 181 | } |
181 | 182 |
|
182 | 183 | /** |
@@ -251,10 +252,10 @@ public DataLoaderRegistry unregister(String key) { |
251 | 252 | * @param key the key of the data loader |
252 | 253 | * @param <K> the type of keys |
253 | 254 | * @param <V> the type of values |
254 | | - * @return a data loader or null if its not present |
| 255 | + * @return a data loader or null if it's not present |
255 | 256 | */ |
256 | 257 | @SuppressWarnings("unchecked") |
257 | | - public <K, V> DataLoader<K, V> getDataLoader(String key) { |
| 258 | + public <K, V> @Nullable DataLoader<K, V> getDataLoader(String key) { |
258 | 259 | return (DataLoader<K, V>) dataLoaders.get(key); |
259 | 260 | } |
260 | 261 |
|
|
0 commit comments