diff --git a/src/main/java/com/commafeed/backend/feed/FeedQueues.java b/src/main/java/com/commafeed/backend/feed/FeedQueues.java index 8af0cfc4..a310bfc9 100644 --- a/src/main/java/com/commafeed/backend/feed/FeedQueues.java +++ b/src/main/java/com/commafeed/backend/feed/FeedQueues.java @@ -7,6 +7,7 @@ import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; +import java.util.stream.Collectors; import javax.inject.Inject; import javax.inject.Singleton; @@ -129,10 +130,7 @@ public class FeedQueues { } // update all feeds in the database - List feeds = new ArrayList<>(); - for (FeedRefreshContext context : map.values()) { - feeds.add(context.getFeed()); - } + List feeds = map.values().stream().map(c -> c.getFeed()).collect(Collectors.toList()); feedDAO.merge(feeds); }