@@ -68,7 +68,7 @@ public Duration getScheduleDuration() {
68
68
*
69
69
* @return a new combined registry
70
70
*/
71
- public DataLoaderRegistry combine (DataLoaderRegistry registry ) {
71
+ public ScheduledDataLoaderRegistry combine (DataLoaderRegistry registry ) {
72
72
Builder combinedBuilder = ScheduledDataLoaderRegistry .newScheduledRegistry ()
73
73
.dispatchPredicate (this .dispatchPredicate );
74
74
combinedBuilder .registerAll (this );
@@ -115,7 +115,7 @@ public DispatchPredicate getDispatchPredicate() {
115
115
*
116
116
* @return this registry
117
117
*/
118
- public DataLoaderRegistry register (String key , DataLoader <?, ?> dataLoader , DispatchPredicate dispatchPredicate ) {
118
+ public ScheduledDataLoaderRegistry register (String key , DataLoader <?, ?> dataLoader , DispatchPredicate dispatchPredicate ) {
119
119
dataLoaders .put (key , dataLoader );
120
120
dataLoaderPredicates .put (dataLoader , dispatchPredicate );
121
121
return this ;
@@ -206,8 +206,8 @@ private void dispatchOrReschedule(String key, DataLoader<?, ?> dataLoader) {
206
206
}
207
207
208
208
/**
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 .
211
211
*
212
212
* @return A builder of {@link ScheduledDataLoaderRegistry}s
213
213
*/
0 commit comments