diff --git a/src/main/java/com/commafeed/backend/feed/FeedQueues.java b/src/main/java/com/commafeed/backend/feed/FeedQueues.java index a5be7f9f..8af0cfc4 100644 --- a/src/main/java/com/commafeed/backend/feed/FeedQueues.java +++ b/src/main/java/com/commafeed/backend/feed/FeedQueues.java @@ -78,13 +78,7 @@ public class FeedQueues { public void add(Feed feed, boolean urgent) { int refreshInterval = config.getApplicationSettings().getRefreshIntervalMinutes(); if (feed.getLastUpdated() == null || feed.getLastUpdated().before(DateUtils.addMinutes(new Date(), -1 * refreshInterval))) { - boolean alreadyQueued = false; - for (FeedRefreshContext context : addQueue) { - if (context.getFeed().getId().equals(feed.getId())) { - alreadyQueued = true; - break; - } - } + boolean alreadyQueued = addQueue.stream().anyMatch(c -> c.getFeed().getId().equals(feed.getId())); if (!alreadyQueued) { addQueue.add(new FeedRefreshContext(feed, urgent)); }