private ScheduledTask nitroScheduleUpdateTask(int back, int forward, Integer threadCount, Integer rateLimit, Optional> fullFetchPermittedPredicate) {
DayRangeChannelDaySupplier drcds = new DayRangeChannelDaySupplier(bbcChannelSupplier(), dayRangeSupplier(back, forward));
ExecutorService executor = Executors.newFixedThreadPool(threadCount, nitroThreadFactory);
<<<<<<< HEAD
return new ChannelDayProcessingTask(executor, drcds, nitroChannelDayProcessor(rateLimit, Optional.of(Predicates.- alwaysTrue())),
=======
return new ChannelDayProcessingTask(executor, drcds, nitroChannelDayProcessor(rateLimit, fullFetchPermittedPredicate),
>>>>>>> ca89150fcf8387b3fdaffeb8347519bf895fa3a9
null, jobFailureThresholdPercent);
}
|