Entwine.Parallel

Documentation

data RunError a

Constructors

WorkerError a

BlowUpError SomeException

Instances

Show a => Show (RunError a)

Defined in Entwine.Parallel

Methods

showsPrec :: Int -> RunError a -> ShowS

show :: RunError a -> String

showList :: [RunError a] -> ShowS

renderRunError :: RunError a -> (a -> Text) -> Text

consume_ :: MonadIO m => (Queue b -> IO a) -> Int -> (b -> EitherT e IO ()) -> EitherT (RunError e) m a

Provide a producer and an action to be run across the result of that producer in parallel.

Common usage: @ let producer :: Address -> Queue Address -> IO () producer prefix q = list' prefix $$ writeQueue q

consume producer 100 ((a :: Address) -> doThis) @

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))