Control.Monad.Hefty.Concurrent.Parallel

Interpreters for the Parallel effects.

Documentation

runConcurrentIO :: forall (eh :: [EffectH]) (ef :: [EffectF]). (UnliftIO <<| eh, IO <| ef) => Eff (Parallel ': (Race ': (Poll ': eh))) (Halt ': ef) ~> Eff eh ef

runHaltIO :: forall (ef :: [EffectF]) (eh :: [EffectH]). IO <| ef => Eff eh (Halt ': ef) ~> Eff eh ef

runPollIO :: forall (ef :: [EffectF]) (eh :: [EffectH]). (IO <| ef, UnliftIO <<| eh) => Eff (Poll ': eh) ef ~> Eff eh ef

runRaceIO :: forall (ef :: [EffectF]) (eh :: [EffectH]). (IO <| ef, UnliftIO <<| eh) => Eff (Race ': eh) ef ~> Eff eh ef

runParallelIO :: forall (eh :: [EffectH]) (ef :: [EffectF]). (UnliftIO <<| eh, IO <| ef) => Eff (Parallel ': eh) ef ~> Eff eh ef

parallelToIO :: forall (m :: Type -> Type). MonadUnliftIO m => Parallel ~~> m

pollToIO :: forall (m :: Type -> Type). MonadUnliftIO m => Poll ~~> m

raceToIO :: forall (m :: Type -> Type). MonadUnliftIO m => Race ~~> m

haltToIO :: forall (m :: Type -> Type). MonadIO m => Halt ~> m

runParallelAsSequential :: forall (eh :: [(Type -> Type) -> Type -> Type]) (ef :: [EffectF]) x. Eff (Parallel ': eh) ef x -> Eff eh ef x

parallelToSequential :: forall (eh :: [EffectH]) (ef :: [EffectF]) x. Parallel (Eff eh ef) x -> Eff eh ef x

polling :: forall (eh :: [EffectH]) (ef :: [EffectF]) a r. Poll <<| eh => Eff eh ef a -> Eff ('[] :: [EffectH]) (Input (Maybe a) ': ef) r -> Eff eh ef r

runForAsParallel :: forall (eh :: [EffectH]) (t :: Type -> Type) (ef :: [EffectF]). (Parallel <<| eh, Traversable t) => Eff (For t ': eh) ef ~> Eff eh ef

module Data.Effect.Concurrent.Parallel

module Data.Effect.Input