|
@ -21,7 +21,7 @@ import GitHub.Data.PullRequests |
|
|
|
|
|
|
|
|
import Control.Applicative |
|
|
import Control.Applicative |
|
|
import Control.Concurrent (threadDelay) |
|
|
import Control.Concurrent (threadDelay) |
|
|
import Control.Concurrent.Async |
|
|
import Control.Concurrent.Async.Pool |
|
|
import DBus.Notify |
|
|
import DBus.Notify |
|
|
import Data.Maybe |
|
|
import Data.Maybe |
|
|
import Data.Vector ((!?)) |
|
|
import Data.Vector ((!?)) |
|
@ -95,8 +95,8 @@ getLatestPRs :: (?pat :: (Maybe Auth.Auth)) => |
|
|
[Repo] -> |
|
|
[Repo] -> |
|
|
IO (Maybe PullRequests) |
|
|
IO (Maybe PullRequests) |
|
|
|
|
|
|
|
|
getLatestPRs repos = do |
|
|
getLatestPRs repos = withTaskGroup 2 $ \g -> do |
|
|
prs <- mapConcurrently getLatest repos |
|
|
prs <- mapConcurrently g getLatest repos |
|
|
return $ maybesToMap prs |
|
|
return $ maybesToMap prs |
|
|
|
|
|
|
|
|
monitorPRs :: (?pat :: (Maybe Auth.Auth)) => |
|
|
monitorPRs :: (?pat :: (Maybe Auth.Auth)) => |
|
|