RelatedAnimeFinderService.java 文件源码

/**
 * @param cache
 *            Instance of the cache.
 * @param app
 *            Instance of the manami app.
 * @param list
 *            List which being checked for related anime.
 * @param observer
 *            Observer which is being notified about the progress. It also
 *            gets the result as a list through notification.
 */
public RelatedAnimeFinderService(final Cache cache, final Manami app, final List<? extends MinimalEntry> list, final Observer observer) {
    this.app = app;
    this.cache = cache;
    this.list = list;
    addObserver(observer);
    myAnime = newArrayList();
    relatedAnime = newHashMap();
    animeToCheck = new Stack<>();
    checkedAnime = new ObservableSetWrapper<>(newHashSet());
    checkedAnime.addListener((SetChangeListener<InfoLink>) event -> {
        setChanged();
        notifyObservers(new ProgressState(checkedAnime.size() + 1, animeToCheck.size()));
    });
}