HGraph.Parallel
produceConsumeExhaustive :: IO (Maybe a) -> (a -> IO b) -> IO (IO (Maybe b)) Source #
Runs the producer until it output Nothing. Each successful product is sent to the consumer. Returns an IO action which takes the next product (or Nothing if there are no more products)
Nothing
processJobList :: (a -> IO ([a], [b])) -> [a] -> IO (IO (Maybe b)) Source #