From 855fb06bc93a628108990013813725996a090c17 Mon Sep 17 00:00:00 2001 From: Frédéric Guillot Date: Tue, 21 Nov 2017 22:36:00 -0800 Subject: Add feature to refresh all feeds from the user interface --- main.go | 24 +++++++++--------------- 1 file changed, 9 insertions(+), 15 deletions(-) (limited to 'main.go') diff --git a/main.go b/main.go index 9ab7cdc..4393472 100644 --- a/main.go +++ b/main.go @@ -44,21 +44,15 @@ func run(cfg *config.Config, store *storage.Storage) { signal.Notify(stop, os.Interrupt) feedHandler := feed.NewFeedHandler(store) - server := server.NewServer(cfg, store, feedHandler) - - go func() { - pool := scheduler.NewWorkerPool( - feedHandler, - cfg.GetInt("WORKER_POOL_SIZE", config.DefaultWorkerPoolSize), - ) - - scheduler.NewScheduler( - store, - pool, - cfg.GetInt("POLLING_FREQUENCY", config.DefaultPollingFrequency), - cfg.GetInt("BATCH_SIZE", config.DefaultBatchSize), - ) - }() + pool := scheduler.NewWorkerPool(feedHandler, cfg.GetInt("WORKER_POOL_SIZE", config.DefaultWorkerPoolSize)) + server := server.NewServer(cfg, store, pool, feedHandler) + + scheduler.NewScheduler( + store, + pool, + cfg.GetInt("POLLING_FREQUENCY", config.DefaultPollingFrequency), + cfg.GetInt("BATCH_SIZE", config.DefaultBatchSize), + ) <-stop log.Println("Shutting down the server...") -- cgit v1.2.3