Skip to content

Commit 1c8d48c

Browse files
committed
Adds a predicate to ScheduledDataLoaderRegistry - no longer in DLR - code tweaks
1 parent c0c6eef commit 1c8d48c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/org/dataloader/registries/ScheduledDataLoaderRegistry.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ public Duration getScheduleDuration() {
6868
*
6969
* @return a new combined registry
7070
*/
71-
public DataLoaderRegistry combine(DataLoaderRegistry registry) {
71+
public ScheduledDataLoaderRegistry combine(DataLoaderRegistry registry) {
7272
Builder combinedBuilder = ScheduledDataLoaderRegistry.newScheduledRegistry()
7373
.dispatchPredicate(this.dispatchPredicate);
7474
combinedBuilder.registerAll(this);
@@ -115,7 +115,7 @@ public DispatchPredicate getDispatchPredicate() {
115115
*
116116
* @return this registry
117117
*/
118-
public DataLoaderRegistry register(String key, DataLoader<?, ?> dataLoader, DispatchPredicate dispatchPredicate) {
118+
public ScheduledDataLoaderRegistry register(String key, DataLoader<?, ?> dataLoader, DispatchPredicate dispatchPredicate) {
119119
dataLoaders.put(key, dataLoader);
120120
dataLoaderPredicates.put(dataLoader, dispatchPredicate);
121121
return this;
@@ -206,8 +206,8 @@ private void dispatchOrReschedule(String key, DataLoader<?, ?> dataLoader) {
206206
}
207207

208208
/**
209-
* By default this will create use a {@link Executors#newSingleThreadScheduledExecutor()}
210-
* and a schedule duration of 10 milli seconds.
209+
* By default, this will create use a {@link Executors#newSingleThreadScheduledExecutor()}
210+
* and a schedule duration of 10 milliseconds.
211211
*
212212
* @return A builder of {@link ScheduledDataLoaderRegistry}s
213213
*/

0 commit comments

Comments
 (0)