Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
The Eff
monad.
This module is intended for internal use only, and may change without warning in subsequent releases.
Synopsis
- data Eff (es :: [Effect]) a
- runPureEff :: Eff '[] a -> a
- unEff :: Eff es a -> Env es -> IO a
- unsafeEff :: (Env es -> IO a) -> Eff es a
- unsafeEff_ :: IO a -> Eff es a
- data NonDet :: Effect where
- data Fail :: Effect where
- data IOE :: Effect
- runEff :: Eff '[IOE] a -> IO a
- data Prim :: Effect
- data PrimStateEff
- runPrim :: IOE :> es => Eff (Prim ': es) a -> Eff es a
- raise :: Eff es a -> Eff (e ': es) a
- raiseWith :: HasCallStack => UnliftStrategy -> ((forall r. Eff (e ': es) r -> Eff es r) -> Eff es a) -> Eff (e ': es) a
- subsume :: e :> es => Eff (e ': es) a -> Eff es a
- inject :: Subset xs es => Eff xs a -> Eff es a
- class KnownPrefix es => Subset (xs :: [Effect]) (es :: [Effect])
- data UnliftStrategy
- data Persistence
- data Limit
- unliftStrategy :: IOE :> es => Eff es UnliftStrategy
- withUnliftStrategy :: IOE :> es => UnliftStrategy -> Eff es a -> Eff es a
- withEffToIO :: (HasCallStack, IOE :> es) => ((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
- withSeqEffToIO :: (HasCallStack, IOE :> es) => ((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
- withConcEffToIO :: (HasCallStack, IOE :> es) => Persistence -> Limit -> ((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
- seqUnliftIO :: HasCallStack => Env es -> ((forall r. Eff es r -> IO r) -> IO a) -> IO a
- concUnliftIO :: HasCallStack => Env es -> Persistence -> Limit -> ((forall r. Eff es r -> IO r) -> IO a) -> IO a
- type EffectHandler e es = forall a localEs. (HasCallStack, e :> localEs) => LocalEnv localEs es -> e (Eff localEs) a -> Eff es a
- newtype LocalEnv (localEs :: [Effect]) (handlerEs :: [Effect]) = LocalEnv (Env localEs)
- data Handler :: Effect -> Type where
- Handler :: !(Env es) -> !(EffectHandler e es) -> Handler e
- relinkHandler :: Relinker Handler e
- runHandler :: DispatchOf e ~ Dynamic => Handler e -> Eff (e ': es) a -> Eff es a
- send :: (HasCallStack, DispatchOf e ~ Dynamic, e :> es) => e (Eff es) a -> Eff es a
- data family StaticRep (e :: Effect) :: Type
- type family MaybeIOE (sideEffects :: SideEffects) (es :: [Effect]) :: Constraint where ...
- runStaticRep :: (DispatchOf e ~ Static sideEffects, MaybeIOE sideEffects es) => StaticRep e -> Eff (e ': es) a -> Eff es (a, StaticRep e)
- evalStaticRep :: (DispatchOf e ~ Static sideEffects, MaybeIOE sideEffects es) => StaticRep e -> Eff (e ': es) a -> Eff es a
- execStaticRep :: (DispatchOf e ~ Static sideEffects, MaybeIOE sideEffects es) => StaticRep e -> Eff (e ': es) a -> Eff es (StaticRep e)
- getStaticRep :: (DispatchOf e ~ Static sideEffects, e :> es) => Eff es (StaticRep e)
- putStaticRep :: (DispatchOf e ~ Static sideEffects, e :> es) => StaticRep e -> Eff es ()
- stateStaticRep :: (DispatchOf e ~ Static sideEffects, e :> es) => (StaticRep e -> (a, StaticRep e)) -> Eff es a
- stateStaticRepM :: (DispatchOf e ~ Static sideEffects, e :> es) => (StaticRep e -> Eff es (a, StaticRep e)) -> Eff es a
- localStaticRep :: (DispatchOf e ~ Static sideEffects, e :> es) => (StaticRep e -> StaticRep e) -> Eff es a -> Eff es a
- consEnv :: EffectRep (DispatchOf e) e -> Relinker (EffectRep (DispatchOf e)) e -> Env es -> IO (Env (e ': es))
- getEnv :: forall e es. e :> es => Env es -> IO (EffectRep (DispatchOf e) e)
- putEnv :: forall e es. e :> es => Env es -> EffectRep (DispatchOf e) e -> IO ()
- stateEnv :: forall e es a. e :> es => Env es -> (EffectRep (DispatchOf e) e -> IO (a, EffectRep (DispatchOf e) e)) -> IO a
- modifyEnv :: forall e es. e :> es => Env es -> (EffectRep (DispatchOf e) e -> IO (EffectRep (DispatchOf e) e)) -> IO ()
The Eff
monad
data Eff (es :: [Effect]) a Source #
The Eff
monad provides the implementation of a computation that performs
an arbitrary set of effects. In
, Eff
es aes
is a type-level list that
contains all the effects that the computation may perform. For example, a
computation that produces an Integer
by consuming a String
from the
global environment and acting upon a single mutable value of type Bool
would have the following type:
(Reader
String
:>
es,State
Bool
:>
es) =>Eff
esInteger
Abstracting over the list of effects with (:>)
:
- Allows the computation to be used in functions that may perform other effects.
- Allows the effects to be handled in any order.
Instances
runPureEff :: Eff '[] a -> a Source #
Access to the internal representation
unsafeEff_ :: IO a -> Eff es a Source #
NonDet
data NonDet :: Effect where Source #
Provide the ability to use the Alternative
and MonadPlus
instance of
Eff
.
Since: 2.2.0.0
Instances
type DispatchOf NonDet Source # | |
Defined in Effectful.Internal.Monad |
Fail
data Fail :: Effect where Source #
Instances
type DispatchOf Fail Source # | |
Defined in Effectful.Internal.Monad |
IO
Run arbitrary IO
computations via MonadIO
or MonadUnliftIO
.
Note: it is not recommended to use this effect in application code as it is too liberal. Ideally, this is only used in handlers of more fine-grained effects.
Instances
type DispatchOf IOE Source # | |
Defined in Effectful.Internal.Monad | |
newtype StaticRep IOE Source # | |
Defined in Effectful.Internal.Monad |
runEff :: Eff '[IOE] a -> IO a Source #
Run an Eff
computation with side effects.
For running pure computations see runPureEff
.
Prim
Provide the ability to perform primitive state-transformer actions.
Instances
type DispatchOf Prim Source # | |
Defined in Effectful.Internal.Monad | |
data StaticRep Prim Source # | |
Defined in Effectful.Internal.Monad |
data PrimStateEff Source #
runPrim :: IOE :> es => Eff (Prim ': es) a -> Eff es a Source #
Run an Eff
computation with primitive state-transformer actions.
Lifting
raise :: Eff es a -> Eff (e ': es) a Source #
Lift an Eff
computation into an effect stack with one more effect.
:: HasCallStack | |
=> UnliftStrategy | |
-> ((forall r. Eff (e ': es) r -> Eff es r) -> Eff es a) | Continuation with the unlifting function in scope. |
-> Eff (e ': es) a |
Lift an Eff
computation into an effect stack with one more effect and
create an unlifting function with the given strategy.
Since: 1.2.0.0
subsume :: e :> es => Eff (e ': es) a -> Eff es a Source #
Eliminate a duplicate effect from the top of the effect stack.
inject :: Subset xs es => Eff xs a -> Eff es a Source #
Allow for running an effect stack xs
within es
as long as xs
is a
permutation (with possible duplicates) of a subset of es
.
Generalizes raise
and subsume
.
>>>
data E1 :: Effect
>>>
data E2 :: Effect
>>>
data E3 :: Effect
It makes it possible to rearrange the effect stack however you like:
>>>
:{
shuffle :: Eff (E3 : E1 : E2 : es) a -> Eff (E1 : E2 : E3 : es) a shuffle = inject :}
Moreover, it allows for hiding specific effects from downstream:
>>>
:{
onlyE1 :: Eff (E1 : es) a -> Eff (E1 : E2 : E3 : es) a onlyE1 = inject :}
>>>
:{
onlyE2 :: Eff (E2 : es) a -> Eff (E1 : E2 : E3 : es) a onlyE2 = inject :}
>>>
:{
onlyE3 :: Eff (E3 : es) a -> Eff (E1 : E2 : E3 : es) a onlyE3 = inject :}
However, it's not possible to inject a computation into an incompatible effect stack:
>>>
:{
coerceEs :: Eff es1 a -> Eff es2 a coerceEs = inject :} ... ...Couldn't match type ‘es1’ with ‘es2’ ...
class KnownPrefix es => Subset (xs :: [Effect]) (es :: [Effect]) Source #
Provide evidence that xs
is a subset of es
.
Instances
(KnownPrefix es, IsUnknownSuffixOf xs es) => Subset xs es Source # | |
Defined in Effectful.Internal.Effect subsetFullyKnown :: Bool Source # reifyIndices :: [Int] Source # | |
KnownPrefix es => Subset ('[] :: [Effect]) es Source # | |
Defined in Effectful.Internal.Effect subsetFullyKnown :: Bool Source # reifyIndices :: [Int] Source # | |
(e :> es, Subset xs es) => Subset (e ': xs) es Source # | |
Defined in Effectful.Internal.Effect subsetFullyKnown :: Bool Source # reifyIndices :: [Int] Source # |
Unlifting
data UnliftStrategy Source #
The strategy to use when unlifting Eff
computations via
withEffToIO
, withRunInIO
or the
localUnlift
family.
SeqUnlift | The fastest strategy and a default setting for |
ConcUnlift !Persistence !Limit | A strategy that makes it possible for the unlifting function to be called
in threads distinct from its creator. See |
Instances
data Persistence Source #
Persistence setting for the ConcUnlift
strategy.
Different functions require different persistence strategies. Examples:
- Lifting
pooledMapConcurrentlyN
from theunliftio
library requires theEphemeral
strategy as we don't want jobs to share environment changes made by previous jobs run in the same worker thread. - Lifting
forkIOWithUnmask
requires thePersistent
strategy, otherwise the unmasking function would start with a fresh environment each time it's called.
Ephemeral | Don't persist the environment between calls to the unlifting function in threads distinct from its creator. |
Persistent | Persist the environment between calls to the unlifting function within a particular thread. |
Instances
Generic Persistence Source # | |
Defined in Effectful.Internal.Unlift type Rep Persistence :: Type -> Type # from :: Persistence -> Rep Persistence x # to :: Rep Persistence x -> Persistence # | |
Show Persistence Source # | |
Defined in Effectful.Internal.Unlift showsPrec :: Int -> Persistence -> ShowS # show :: Persistence -> String # showList :: [Persistence] -> ShowS # | |
Eq Persistence Source # | |
Defined in Effectful.Internal.Unlift (==) :: Persistence -> Persistence -> Bool # (/=) :: Persistence -> Persistence -> Bool # | |
Ord Persistence Source # | |
Defined in Effectful.Internal.Unlift compare :: Persistence -> Persistence -> Ordering # (<) :: Persistence -> Persistence -> Bool # (<=) :: Persistence -> Persistence -> Bool # (>) :: Persistence -> Persistence -> Bool # (>=) :: Persistence -> Persistence -> Bool # max :: Persistence -> Persistence -> Persistence # min :: Persistence -> Persistence -> Persistence # | |
type Rep Persistence Source # | |
Defined in Effectful.Internal.Unlift |
Limit setting for the ConcUnlift
strategy.
Limited !Int | Behavior dependent on the For For |
Unlimited | Unlimited use of the unlifting function. |
Instances
Generic Limit Source # | |
Show Limit Source # | |
Eq Limit Source # | |
Ord Limit Source # | |
type Rep Limit Source # | |
Defined in Effectful.Internal.Unlift type Rep Limit = D1 ('MetaData "Limit" "Effectful.Internal.Unlift" "effectful-core-2.2.2.0-ESmopo7RCWo4CzONmM3RMg" 'False) (C1 ('MetaCons "Limited" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int)) :+: C1 ('MetaCons "Unlimited" 'PrefixI 'False) (U1 :: Type -> Type)) |
unliftStrategy :: IOE :> es => Eff es UnliftStrategy Source #
Get the current UnliftStrategy
.
withUnliftStrategy :: IOE :> es => UnliftStrategy -> Eff es a -> Eff es a Source #
Locally override the UnliftStrategy
with the given value.
:: (HasCallStack, IOE :> es) | |
=> ((forall r. Eff es r -> IO r) -> IO a) | Continuation with the unlifting function in scope. |
-> Eff es a |
Create an unlifting function with the current UnliftStrategy
.
This function is equivalent to withRunInIO
, but has a
HasCallStack
constraint for accurate stack traces in case an insufficiently
powerful UnliftStrategy
is used and the unlifting function fails.
:: (HasCallStack, IOE :> es) | |
=> ((forall r. Eff es r -> IO r) -> IO a) | Continuation with the unlifting function in scope. |
-> Eff es a |
Create an unlifting function with the SeqUnlift
strategy.
:: (HasCallStack, IOE :> es) | |
=> Persistence | |
-> Limit | |
-> ((forall r. Eff es r -> IO r) -> IO a) | Continuation with the unlifting function in scope. |
-> Eff es a |
Create an unlifting function with the ConcUnlift
strategy.
Low-level unlifts
:: HasCallStack | |
=> Env es | The environment. |
-> ((forall r. Eff es r -> IO r) -> IO a) | Continuation with the unlifting function in scope. |
-> IO a |
Create an unlifting function with the SeqUnlift
strategy.
:: HasCallStack | |
=> Env es | The environment. |
-> Persistence | |
-> Limit | |
-> ((forall r. Eff es r -> IO r) -> IO a) | Continuation with the unlifting function in scope. |
-> IO a |
Create an unlifting function with the ConcUnlift
strategy.
Dispatch
Dynamic dispatch
type EffectHandler e es Source #
= forall a localEs. (HasCallStack, e :> localEs) | |
=> LocalEnv localEs es | Capture of the local environment for handling local |
-> e (Eff localEs) a | The effect performed in the local environment. |
-> Eff es a |
Type signature of the effect handler.
newtype LocalEnv (localEs :: [Effect]) (handlerEs :: [Effect]) Source #
Opaque representation of the Eff
environment at the point of calling the
send
function, i.e. right before the control is passed to the effect
handler.
The second type variable represents effects of a handler and is needed for
technical reasons to guarantee soundness (see
SharedSuffix
for more information).
data Handler :: Effect -> Type where Source #
An internal representation of dynamically dispatched effects, i.e. the effect handler bundled with its environment.
Handler :: !(Env es) -> !(EffectHandler e es) -> Handler e |
relinkHandler :: Relinker Handler e Source #
runHandler :: DispatchOf e ~ Dynamic => Handler e -> Eff (e ': es) a -> Eff es a Source #
Run a dynamically dispatched effect with the given handler.
:: (HasCallStack, DispatchOf e ~ Dynamic, e :> es) | |
=> e (Eff es) a | The effect. |
-> Eff es a |
Send an operation of the given effect to its handler for execution.
Static dispatch
data family StaticRep (e :: Effect) :: Type Source #
Internal representations of statically dispatched effects.
Instances
newtype StaticRep IOE Source # | |
Defined in Effectful.Internal.Monad | |
data StaticRep Prim Source # | |
Defined in Effectful.Internal.Monad | |
newtype StaticRep (Error e) Source # | |
Defined in Effectful.Error.Static | |
newtype StaticRep (Reader r) Source # | |
Defined in Effectful.Reader.Static | |
newtype StaticRep (State s) Source # | |
Defined in Effectful.State.Static.Local | |
newtype StaticRep (State s) Source # | |
Defined in Effectful.State.Static.Shared | |
newtype StaticRep (Writer w) Source # | |
Defined in Effectful.Writer.Static.Local | |
newtype StaticRep (Writer w) Source # | |
Defined in Effectful.Writer.Static.Shared |
type family MaybeIOE (sideEffects :: SideEffects) (es :: [Effect]) :: Constraint where ... Source #
Require the IOE
effect for running statically dispatched effects whose
operations perform side effects.
MaybeIOE NoSideEffects _ = () | |
MaybeIOE WithSideEffects es = IOE :> es |
:: (DispatchOf e ~ Static sideEffects, MaybeIOE sideEffects es) | |
=> StaticRep e | The initial representation. |
-> Eff (e ': es) a | |
-> Eff es (a, StaticRep e) |
Run a statically dispatched effect with the given initial representation and return the final value along with the final representation.
:: (DispatchOf e ~ Static sideEffects, MaybeIOE sideEffects es) | |
=> StaticRep e | The initial representation. |
-> Eff (e ': es) a | |
-> Eff es a |
Run a statically dispatched effect with the given initial representation and return the final value, discarding the final representation.
:: (DispatchOf e ~ Static sideEffects, MaybeIOE sideEffects es) | |
=> StaticRep e | The initial representation. |
-> Eff (e ': es) a | |
-> Eff es (StaticRep e) |
Run a statically dispatched effect with the given initial representation and return the final representation, discarding the final value.
getStaticRep :: (DispatchOf e ~ Static sideEffects, e :> es) => Eff es (StaticRep e) Source #
Fetch the current representation of the effect.
putStaticRep :: (DispatchOf e ~ Static sideEffects, e :> es) => StaticRep e -> Eff es () Source #
Set the current representation of the effect to the given value.
:: (DispatchOf e ~ Static sideEffects, e :> es) | |
=> (StaticRep e -> (a, StaticRep e)) | The function to modify the representation. |
-> Eff es a |
Apply the function to the current representation of the effect and return a value.
:: (DispatchOf e ~ Static sideEffects, e :> es) | |
=> (StaticRep e -> Eff es (a, StaticRep e)) | The function to modify the representation. |
-> Eff es a |
Apply the monadic function to the current representation of the effect and return a value.
:: (DispatchOf e ~ Static sideEffects, e :> es) | |
=> (StaticRep e -> StaticRep e) | The function to temporarily modify the representation. |
-> Eff es a | |
-> Eff es a |
Execute a computation with a temporarily modified representation of the effect.
Primitive operations
:: EffectRep (DispatchOf e) e | The representation of the effect. |
-> Relinker (EffectRep (DispatchOf e)) e | |
-> Env es | |
-> IO (Env (e ': es)) |
Extend the environment with a new data type.
:: forall e es. e :> es | |
=> Env es | The environment. |
-> IO (EffectRep (DispatchOf e) e) |
Extract a specific data type from the environment.
:: forall e es. e :> es | |
=> Env es | The environment. |
-> EffectRep (DispatchOf e) e | |
-> IO () |
Replace the data type in the environment with a new value (in place).
:: forall e es a. e :> es | |
=> Env es | The environment. |
-> (EffectRep (DispatchOf e) e -> IO (a, EffectRep (DispatchOf e) e)) | |
-> IO a |
Modify the data type in the environment and return a value (in place).