Skip to content

Implemented a Parallel instance #33

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Implemented a Parallel instance #33

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 30 additions & 2 deletions src/Run.purs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ module Run
, expand
, EFFECT
, AFF
, PAR_AFF
, liftEffect
, liftAff
, runBaseEffect
Expand All @@ -34,15 +35,16 @@ import Control.Alternative (class Alternative)
import Control.Monad.Free (Free, liftF, runFree, runFreeM, resume')
import Control.Monad.Rec.Class (Step(..)) as Exports
import Control.Monad.Rec.Class (class MonadRec, Step(..), tailRecM)
import Control.Parallel (class Parallel, parallel, sequential)
import Control.Plus (class Plus)
import Data.Either (Either(..))
import Data.Functor.Variant (FProxy(..), VariantF, case_, default, inj, match, on, onMatch)
import Data.Functor.Variant (FProxy(..), SProxy(..), VariantF, case_, default, inj, match, on, onMatch)
import Data.Newtype (class Newtype, unwrap)
import Data.Symbol (SProxy(..)) as Exports
import Data.Symbol (SProxy(..), class IsSymbol)
import Data.Tuple (Tuple(..), curry, uncurry)
import Effect (Effect)
import Effect.Aff (Aff)
import Effect.Aff (Aff, ParAff)
import Effect.Aff.Class (class MonadAff)
import Effect.Class (class MonadEffect)
import Effect.Class as Effect
Expand Down Expand Up @@ -322,6 +324,9 @@ runBaseEffect = runRec $ match { effect: \a → a }
-- | Type synonym for using `Aff` as an effect.
type AFF = FProxy Aff

-- | Type synonym for using `ParAff` as an effect.
type PAR_AFF = FProxy ParAff

-- | Lift an `Aff` effect into the `Run` Monad via the `aff` label.
liftAff ∷ ∀ r. Aff ~> Run (aff ∷ AFF | r)
liftAff = lift (SProxy ∷ SProxy "aff")
Expand All @@ -342,6 +347,29 @@ instance runMonadEffect ∷ (TypeEquals (RProxy r1) (RProxy (effect ∷ EFFECT |
instance runMonadAff ∷ (TypeEquals (RProxy r1) (RProxy (aff ∷ AFF, effect ∷ EFFECT | r2))) ⇒ MonadAff (Run r1) where
liftAff = fromRows <<< liftAff

instance runParallel ::
(TypeEquals (RProxy r1) (RProxy (aff :: AFF | r2))
,TypeEquals (RProxy r3) (RProxy (parAff :: PAR_AFF | r2)))
=> Parallel (Run r3) (Run r1) where
-- The unsafeCoerce is there because the compiler can't find the Row.Union instance (so I can't use `expand`)
-- It basically coerces from ( aff :: AFF | r2 ) to ( parAff :: PAR_AFF, aff :: AFF | r2 )
parallel
= toRows
>>> unsafeCoerce
>>> interpretRec (on (SProxy :: SProxy "aff") handleAff send)
>>> fromRows
where
handleAff :: forall a r. Aff a -> Run ( parAff :: PAR_AFF | r ) a
handleAff = parallel >>> lift (SProxy :: SProxy "parAff")
sequential
= toRows
>>> unsafeCoerce
>>> interpretRec (on (SProxy :: SProxy "parAff") handleParAff send)
>>> fromRows
where
handleParAff :: forall a r. ParAff a -> Run ( aff :: AFF | r ) a
handleParAff = sequential >>> lift (SProxy :: SProxy "aff")

liftChoose ∷ ∀ r a. Choose a → Run (choose ∷ CHOOSE | r) a
liftChoose = lift _choose

Expand Down