mirror of https://github.com/zlatinb/muwire
load feeds after the UI loads
parent
9c57e43a9f
commit
47b841cf3d
|
@ -404,6 +404,7 @@ public class Core {
|
||||||
log.info("initializing feed manager")
|
log.info("initializing feed manager")
|
||||||
feedManager = new FeedManager(eventBus, home)
|
feedManager = new FeedManager(eventBus, home)
|
||||||
eventBus.with {
|
eventBus.with {
|
||||||
|
register(UILoadedEvent.class, feedManager)
|
||||||
register(FeedItemFetchedEvent.class, feedManager)
|
register(FeedItemFetchedEvent.class, feedManager)
|
||||||
register(FeedFetchEvent.class, feedManager)
|
register(FeedFetchEvent.class, feedManager)
|
||||||
register(UIFeedConfigurationEvent.class, feedManager)
|
register(UIFeedConfigurationEvent.class, feedManager)
|
||||||
|
@ -557,7 +558,6 @@ public class Core {
|
||||||
connectionEstablisher.start()
|
connectionEstablisher.start()
|
||||||
hostCache.waitForLoad()
|
hostCache.waitForLoad()
|
||||||
updateClient?.start()
|
updateClient?.start()
|
||||||
feedManager.start()
|
|
||||||
feedClient.start()
|
feedClient.start()
|
||||||
trackerResponder.start()
|
trackerResponder.start()
|
||||||
|
|
||||||
|
|
|
@ -1,5 +1,7 @@
|
||||||
package com.muwire.core.filefeeds
|
package com.muwire.core.filefeeds
|
||||||
|
|
||||||
|
import com.muwire.core.UILoadedEvent
|
||||||
|
|
||||||
import java.nio.file.Files
|
import java.nio.file.Files
|
||||||
import java.util.concurrent.ConcurrentHashMap
|
import java.util.concurrent.ConcurrentHashMap
|
||||||
import java.util.concurrent.ExecutorService
|
import java.util.concurrent.ExecutorService
|
||||||
|
@ -59,7 +61,7 @@ class FeedManager {
|
||||||
.collect(Collectors.toList())
|
.collect(Collectors.toList())
|
||||||
}
|
}
|
||||||
|
|
||||||
void start() {
|
void onUILoadedEvent(UILoadedEvent event) {
|
||||||
log.info("starting feed manager")
|
log.info("starting feed manager")
|
||||||
persister.submit({loadFeeds()} as Runnable)
|
persister.submit({loadFeeds()} as Runnable)
|
||||||
persister.submit({loadItems()} as Runnable)
|
persister.submit({loadItems()} as Runnable)
|
||||||
|
|
Loading…
Reference in New Issue