Mismi.S3.Internal.Parallel

Contents

• Data
• Operations

Synopsis

• data Workers a
• data Result a
• newResult :: a -> IO (Result a)
• emptyResult :: IO (Result a)
• addResult :: Monad m => Result (m a) -> m a -> IO (m a)
• getResult :: Result a -> IO a
• emptyWorkers :: IO (Workers a)
• failWorkers :: Workers a -> IO ()
• getWorkers :: Workers a -> IO [Async a]
• addWorker :: Workers a -> Async a -> IO ()
• waitForWorkers :: Workers a -> IO ()
• waitForWorkers' :: Workers a -> IO [a]
• data RunError a
  • = WorkerError a
  • | BlowUpError SomeException
• renderRunError :: RunError a -> (a -> Text) -> Text
• consume_ :: MonadIO m => (Queue b -> IO a) -> Int -> (b -> ExceptT e IO ()) -> ExceptT (RunError e) m a
• consume :: forall a b c e. (Queue a -> IO b) -> Int -> (a -> IO (Either e c)) -> IO (Either (RunError e) (b, [c]))
• waitEitherBoth :: Async a -> Async b -> Async c -> IO (Either a (b, c))

Data

Operations