-- Hoogle documentation, generated by Haddock
-- See Hoogle, http://www.haskell.org/hoogle/


-- | Message passing concurrency as extensible-effect
--   
--   Please see the README on GitHub at
--   <a>https://github.com/sheyll/extensible-effects-concurrent#readme</a>
@package extensible-effects-concurrent
@version 0.19.0


-- | Add-ons to <a>Exception</a> and <a>Exception</a>
module Control.Eff.ExceptionExtra

-- | Catch <a>Exception</a> thrown by an effect.
liftTry :: forall e r a. (HasCallStack, Exception e, Lifted IO r) => Eff r a -> Eff r (Either e a)

-- | Very similar to <a>liftEither</a> but for <a>Maybe</a>s. Unlike
--   <a>liftMaybe</a> this will throw the given value (instead of using
--   <a>Fail</a>).
maybeThrow :: Member (Exc x) e => x -> Maybe a -> Eff e a
instance Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Reader.Lazy.Reader x : e))
instance Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Reader.Lazy.Reader x : e))
instance Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Reader.Lazy.Reader x : e))
instance Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Reader.Strict.Reader x : e))
instance Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Reader.Strict.Reader x : e))
instance Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Reader.Strict.Reader x : e))
instance Control.Monad.Catch.MonadThrow m => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff '[Control.Eff.Internal.Lift m])
instance Control.Monad.Catch.MonadCatch m => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff '[Control.Eff.Internal.Lift m])
instance Control.Monad.Catch.MonadMask m => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff '[Control.Eff.Internal.Lift m])
instance Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Exception.Exc x : e))
instance Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Exception.Exc x : e))
instance Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Exception.Exc x : e))


-- | An RFC 5434 inspired log message and convenience functions for logging
--   them.
module Control.Eff.Log.Message

-- | A message data type inspired by the RFC-5424 Syslog Protocol
data LogMessage
MkLogMessage :: !Facility -> !Severity -> !Maybe UTCTime -> !Maybe String -> !Maybe String -> !Maybe String -> !Maybe String -> ![StructuredDataElement] -> !Maybe ThreadId -> !Maybe SrcLoc -> !String -> LogMessage
[_lmFacility] :: LogMessage -> !Facility
[_lmSeverity] :: LogMessage -> !Severity
[_lmTimestamp] :: LogMessage -> !Maybe UTCTime
[_lmHostname] :: LogMessage -> !Maybe String
[_lmAppName] :: LogMessage -> !Maybe String
[_lmProcessId] :: LogMessage -> !Maybe String
[_lmMessageId] :: LogMessage -> !Maybe String
[_lmStructuredData] :: LogMessage -> ![StructuredDataElement]
[_lmThreadId] :: LogMessage -> !Maybe ThreadId
[_lmSrcLoc] :: LogMessage -> !Maybe SrcLoc
[_lmMessage] :: LogMessage -> !String

-- | A lens for the <a>Facility</a> of a <a>LogMessage</a>
lmFacility :: Functor f => (Facility -> f Facility) -> LogMessage -> f LogMessage

-- | A lens for the <a>Severity</a> of a <a>LogMessage</a>
lmSeverity :: Functor f => (Severity -> f Severity) -> LogMessage -> f LogMessage

-- | A lens for the UTC time of a <a>LogMessage</a> The function
--   <a>setLogMessageTimestamp</a> can be used to set the field.
lmTimestamp :: Functor f => (Maybe UTCTime -> f (Maybe UTCTime)) -> LogMessage -> f LogMessage

-- | A lens for the hostname of a <a>LogMessage</a> The function
--   <a>setLogMessageHostname</a> can be used to set the field.
lmHostname :: Functor f => (Maybe String -> f (Maybe String)) -> LogMessage -> f LogMessage

-- | A lens for the RFC 5424 <i>application</i> name of a <a>LogMessage</a>
--   
--   One useful pattern for using this field, is to implement log filters
--   that allow info and debug message from the application itself while
--   only allowing warning and error messages from third party libraries:
--   
--   <pre>
--   debugLogsForAppName myAppName lm =
--     view lmAppName lm == Just myAppName || lmSeverityIsAtLeast warningSeverity lm
--   </pre>
--   
--   This is implemented in <a>discriminateByAppName</a>.
lmAppName :: Functor f => (Maybe String -> f (Maybe String)) -> LogMessage -> f LogMessage

-- | A lens for a user defined of <i>process</i> id of a <a>LogMessage</a>
lmProcessId :: Functor f => (Maybe String -> f (Maybe String)) -> LogMessage -> f LogMessage

-- | A lens for a user defined <i>message id</i> of a <a>LogMessage</a>
lmMessageId :: Functor f => (Maybe String -> f (Maybe String)) -> LogMessage -> f LogMessage

-- | A lens for the <a>StructuredDataElement</a> of a <a>LogMessage</a>
lmStructuredData :: Functor f => ([StructuredDataElement] -> f [StructuredDataElement]) -> LogMessage -> f LogMessage

-- | A lens for the <a>SrcLoc</a> of a <a>LogMessage</a>
lmSrcLoc :: Functor f => (Maybe SrcLoc -> f (Maybe SrcLoc)) -> LogMessage -> f LogMessage

-- | A lens for the <a>ThreadId</a> of a <a>LogMessage</a> The function
--   <a>setLogMessageThreadId</a> can be used to set the field.
lmThreadId :: Functor f => (Maybe ThreadId -> f (Maybe ThreadId)) -> LogMessage -> f LogMessage

-- | A lens for the user defined textual message of a <a>LogMessage</a>
lmMessage :: Functor f => (String -> f String) -> LogMessage -> f LogMessage

-- | Put the source location of the given callstack in <a>lmSrcLoc</a>
setCallStack :: CallStack -> LogMessage -> LogMessage

-- | Prefix the <a>lmMessage</a>.
prefixLogMessagesWith :: String -> LogMessage -> LogMessage

-- | An IO action that sets the current UTC time in <a>lmTimestamp</a>.
setLogMessageTimestamp :: LogMessage -> IO LogMessage

-- | An IO action appends the the <a>ThreadId</a> of the calling process
--   (see <a>myThreadId</a>) to <a>lmMessage</a>.
setLogMessageThreadId :: LogMessage -> IO LogMessage

-- | An IO action that sets the current hosts fully qualified hostname in
--   <a>lmHostname</a>.
setLogMessageHostname :: LogMessage -> IO LogMessage

-- | Render a <a>LogMessage</a> according to the rules in the given RFC,
--   except for the rules concerning unicode and ascii
renderRFC5424 :: LogMessage -> String

-- | Render a <a>LogMessage</a> but set the timestamp and thread id fields.
printLogMessage :: LogMessage -> IO ()

-- | Render a <a>LogMessage</a> human readable.
renderLogMessage :: LogMessage -> String

-- | Construct a <a>LogMessage</a> with <a>errorSeverity</a>
errorMessage :: HasCallStack => String -> LogMessage

-- | Construct a <a>LogMessage</a> with <a>informationalSeverity</a>
infoMessage :: HasCallStack => String -> LogMessage

-- | Construct a <a>LogMessage</a> with <a>debugSeverity</a>
debugMessage :: HasCallStack => String -> LogMessage

-- | Things that can become a <a>LogMessage</a>
class ToLogMessage a

-- | Convert the value to a <a>LogMessage</a>
toLogMessage :: ToLogMessage a => a -> LogMessage

-- | Construct a <a>LogMessage</a> with <a>errorSeverity</a>
errorMessageIO :: (HasCallStack, MonadIO m) => String -> m LogMessage

-- | Construct a <a>LogMessage</a> with <a>informationalSeverity</a>
infoMessageIO :: (HasCallStack, MonadIO m) => String -> m LogMessage

-- | Construct a <a>LogMessage</a> with <a>debugSeverity</a>
debugMessageIO :: (HasCallStack, MonadIO m) => String -> m LogMessage

-- | The filter predicate for message that shall be logged.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
type LogPredicate = LogMessage -> Bool

-- | All messages.
allLogMessages :: LogPredicate

-- | No messages.
noLogMessages :: LogPredicate

-- | Match <a>LogMessage</a>s that have exactly the given severity. See
--   <a>lmSeverityIsAtLeast</a>.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
lmSeverityIs :: Severity -> LogPredicate

-- | Match <a>LogMessage</a>s that have the given severity <b>or worse</b>.
--   See <a>lmSeverityIs</a>.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
lmSeverityIsAtLeast :: Severity -> LogPredicate

-- | Match <a>LogMessage</a>s whose <a>lmMessage</a> starts with the given
--   string.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
lmMessageStartsWith :: String -> LogPredicate

-- | Apply discriminate <a>LogMessage</a>s by their <a>lmAppName</a> and
--   delegate to one of two <a>LogPredicate</a>s.
--   
--   One useful application for this is to allow info and debug message
--   from one application, e.g. the current application itself, while at
--   the same time allowing only warning and error messages from third
--   party libraries.
discriminateByAppName :: String -> LogPredicate -> LogPredicate -> LogPredicate

-- | RFC-5424 defines how structured data can be included in a log message.
data StructuredDataElement
SdElement :: !String -> ![SdParameter] -> StructuredDataElement
[_sdElementId] :: StructuredDataElement -> !String
[_sdElementParameters] :: StructuredDataElement -> ![SdParameter]

-- | Component of an RFC-5424 <a>StructuredDataElement</a>
data SdParameter
MkSdParameter :: !String -> !String -> SdParameter

-- | Extract the name of an <a>SdParameter</a> the length is cropped to 32
--   according to RFC 5424.
sdName :: String -> String

-- | Extract the value of an <a>SdParameter</a>.
sdParamValue :: String -> String

-- | A lens for the key or ID of a group of RFC 5424 key-value pairs.
sdElementId :: Functor f => (String -> f String) -> StructuredDataElement -> f StructuredDataElement

-- | A lens for <a>SdParameter</a>s
sdElementParameters :: Functor f => ([SdParameter] -> f [SdParameter]) -> StructuredDataElement -> f StructuredDataElement

-- | An rfc 5424 severity
data Severity

-- | Smart constructor for the RFC-5424 <b>emergency</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>0</b>. See
--   <a>lmSeverity</a>.
emergencySeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>alert</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>1</b>. See
--   <a>lmSeverity</a>.
alertSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>critical</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>2</b>. See
--   <a>lmSeverity</a>.
criticalSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>error</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>3</b>. See
--   <a>lmSeverity</a>.
errorSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>warning</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>4</b>. See
--   <a>lmSeverity</a>.
warningSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>notice</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>5</b>. See
--   <a>lmSeverity</a>.
noticeSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>informational</b>
--   <a>LogMessage</a> <a>Severity</a>. This corresponds to the severity
--   value <b>6</b>. See <a>lmSeverity</a>.
informationalSeverity :: Severity

-- | Smart constructor for the RFC-5424 <b>debug</b> <a>LogMessage</a>
--   <a>Severity</a>. This corresponds to the severity value <b>7</b>. See
--   <a>lmSeverity</a>.
debugSeverity :: Severity

-- | An rfc 5424 facility
data Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>kernelMessages</tt>. See <a>lmFacility</a>.
kernelMessages :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>userLevelMessages</tt>. See <a>lmFacility</a>.
userLevelMessages :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>mailSystem</tt>. See <a>lmFacility</a>.
mailSystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>systemDaemons</tt>. See <a>lmFacility</a>.
systemDaemons :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>securityAuthorizationMessages4</tt>. See <a>lmFacility</a>.
securityAuthorizationMessages4 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>linePrinterSubsystem</tt>. See <a>lmFacility</a>.
linePrinterSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>networkNewsSubsystem</tt>. See <a>lmFacility</a>.
networkNewsSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>uucpSubsystem</tt>. See <a>lmFacility</a>.
uucpSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>clockDaemon</tt>. See <a>lmFacility</a>.
clockDaemon :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>securityAuthorizationMessages10</tt>. See <a>lmFacility</a>.
securityAuthorizationMessages10 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>ftpDaemon</tt>. See <a>lmFacility</a>.
ftpDaemon :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>ntpSubsystem</tt>. See <a>lmFacility</a>.
ntpSubsystem :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>logAuditFacility</tt>. See <a>lmFacility</a>.
logAuditFacility :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>logAlertFacility</tt>. See <a>lmFacility</a>.
logAlertFacility :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>clockDaemon2</tt>. See <a>lmFacility</a>.
clockDaemon2 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local0</tt>. See <a>lmFacility</a>.
local0 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local1</tt>. See <a>lmFacility</a>.
local1 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local2</tt>. See <a>lmFacility</a>.
local2 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local3</tt>. See <a>lmFacility</a>.
local3 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local4</tt>. See <a>lmFacility</a>.
local4 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local5</tt>. See <a>lmFacility</a>.
local5 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local6</tt>. See <a>lmFacility</a>.
local6 :: Facility

-- | Smart constructor for the RFC-5424 <a>LogMessage</a> facility
--   <tt>local7</tt>. See <a>lmFacility</a>.
local7 :: Facility
instance Control.Eff.Log.Message.ToLogMessage Control.Eff.Log.Message.LogMessage
instance Control.Eff.Log.Message.ToLogMessage GHC.Base.String
instance GHC.Show.Show Control.Eff.Log.Message.LogMessage
instance Data.String.IsString Control.Eff.Log.Message.LogMessage
instance GHC.Generics.Generic Control.Eff.Log.Message.LogMessage
instance GHC.Classes.Eq Control.Eff.Log.Message.LogMessage
instance Control.DeepSeq.NFData Control.Eff.Log.Message.Facility
instance GHC.Generics.Generic Control.Eff.Log.Message.Facility
instance GHC.Show.Show Control.Eff.Log.Message.Facility
instance GHC.Classes.Ord Control.Eff.Log.Message.Facility
instance GHC.Classes.Eq Control.Eff.Log.Message.Facility
instance Control.DeepSeq.NFData Control.Eff.Log.Message.Severity
instance GHC.Generics.Generic Control.Eff.Log.Message.Severity
instance GHC.Classes.Ord Control.Eff.Log.Message.Severity
instance GHC.Classes.Eq Control.Eff.Log.Message.Severity
instance GHC.Generics.Generic Control.Eff.Log.Message.StructuredDataElement
instance GHC.Classes.Ord Control.Eff.Log.Message.StructuredDataElement
instance GHC.Classes.Eq Control.Eff.Log.Message.StructuredDataElement
instance GHC.Generics.Generic Control.Eff.Log.Message.SdParameter
instance GHC.Classes.Ord Control.Eff.Log.Message.SdParameter
instance GHC.Classes.Eq Control.Eff.Log.Message.SdParameter
instance Data.Default.Class.Default Control.Eff.Log.Message.LogMessage
instance Control.DeepSeq.NFData Control.Eff.Log.Message.LogMessage
instance Data.Default.Class.Default Control.Eff.Log.Message.Facility
instance GHC.Show.Show Control.Eff.Log.Message.Severity
instance Data.Default.Class.Default Control.Eff.Log.Message.Severity
instance GHC.Show.Show Control.Eff.Log.Message.StructuredDataElement
instance Control.DeepSeq.NFData Control.Eff.Log.Message.StructuredDataElement
instance GHC.Show.Show Control.Eff.Log.Message.SdParameter
instance Control.DeepSeq.NFData Control.Eff.Log.Message.SdParameter


-- | The <a>LogWriter</a> type encapsulates an effectful function to write
--   <a>LogMessage</a>s.
--   
--   Used in conjunction with the <a>SupportsLogger</a> class, it can be
--   used to write messages from within an effectful computation.
module Control.Eff.Log.Writer

-- | A function that takes a log message and returns an effect that
--   <i>logs</i> the message.
newtype LogWriter writerM
MkLogWriter :: (LogMessage -> writerM ()) -> LogWriter writerM
[runLogWriter] :: LogWriter writerM -> LogMessage -> writerM ()

-- | This class describes how to lift the log writer action into some
--   monad.
--   
--   The second parameter is almost always <tt>Eff x</tt> so usually the
--   method of this class lifts the log writer action into an effect monad.
class SupportsLogger h e
liftLogWriter :: SupportsLogger h e => LogWriter h -> LogMessage -> Eff e ()

-- | This <a>LogWriter</a> will discard all messages.
--   
--   NOTE: This is just an alias for <a>def</a>
noOpLogWriter :: Applicative m => LogWriter m

-- | A <a>LogWriter</a> that applies <a>renderLogMessage</a> to the log
--   message and then traces it using <a>traceM</a>. This <a>LogWriter</a>
--   work with <i>any</i> base monad.
debugTraceLogWriter :: Monad h => LogWriter h

-- | A base monad for all side effect free <a>LogWriter</a>.
--   
--   This is only required e.g. when logs are only either discarded or
--   traced. See <a>debugTraceLogWriter</a> or <a>noOpLogWriter</a>.
--   
--   This is just a wrapper around <a>Identity</a> and serves as a type
--   that has a special <a>SupportsLogger</a> instance.
newtype PureLogWriter a
MkPureLogWriter :: Identity a -> PureLogWriter a
[runPureLogWriter] :: PureLogWriter a -> Identity a

-- | A <a>LogWriter</a> monad that provides pure logging by capturing via
--   the <a>Writer</a> effect.
listLogWriter :: LogWriter CaptureLogs

-- | A <a>LogWriter</a> monad that provides pure logging by capturing via
--   the <a>Writer</a> effect.
newtype CaptureLogs a
MkCaptureLogs :: Eff '[CapturedLogsWriter] a -> CaptureLogs a
[unCaptureLogs] :: CaptureLogs a -> Eff '[CapturedLogsWriter] a

-- | Alias for the <a>Writer</a> that contains the captured
--   <a>LogMessage</a>s from <a>CaptureLogs</a>.
type CapturedLogsWriter = Writer LogMessage

-- | Run a <a>Writer</a> for <a>LogMessage</a>s.
--   
--   Such a <a>Writer</a> is needed for <a>CaptureLogs</a>
runCapturedLogsWriter :: Eff (CapturedLogsWriter : e) a -> Eff e (a, [LogMessage])

-- | Write <a>LogMessage</a>s to standard output, formatted with
--   <a>printLogMessage</a>.
consoleLogWriter :: LogWriter IO

-- | A <a>LogWriter</a> that uses an <a>IO</a> action to write the message.
ioHandleLogWriter :: HasCallStack => Handle -> LogWriter IO

-- | A <a>LogWriter</a> that applies a predicate to the <a>LogMessage</a>
--   and delegates to to the given writer of the predicate is satisfied.
filteringLogWriter :: Monad e => LogPredicate -> LogWriter e -> LogWriter e

-- | A <a>LogWriter</a> that applies a function to the <a>LogMessage</a>
--   and delegates the result to to the given writer.
mappingLogWriter :: (LogMessage -> LogMessage) -> LogWriter e -> LogWriter e

-- | Like <a>mappingLogWriter</a> allow the function that changes the
--   <a>LogMessage</a> to have effects.
mappingLogWriterM :: Monad e => (LogMessage -> e LogMessage) -> LogWriter e -> LogWriter e

-- | A <a>LogWriter</a> that uses an <a>IO</a> action to write the message.
--   
--   Example use cases for this function are the <a>consoleLogWriter</a>
--   and the <a>ioHandleLogWriter</a>.
ioLogWriter :: HasCallStack => (LogMessage -> IO ()) -> LogWriter IO

-- | Decorate an IO based <a>LogWriter</a> to set important fields in log
--   messages.
--   
--   ALl log messages are censored to include basic log message
--   information:
--   
--   <ul>
--   <li>The messages will carry the given application name in the
--   <a>lmAppName</a> field.</li>
--   <li>The <a>lmTimestamp</a> field contains the UTC time of the log
--   event</li>
--   <li>The <a>lmThreadId</a> field contains the thread-Id</li>
--   <li>The <a>lmHostname</a> field contains the FQDN of the current
--   host</li>
--   <li>The <a>lmFacility</a> field contains the given
--   <a>Facility</a></li>
--   </ul>
--   
--   It installs the given <a>LogWriter</a>, wrapped using
--   <a>mappingLogWriterM</a>.
defaultIoLogWriter :: String -> Facility -> LogWriter IO -> LogWriter IO
instance GHC.Base.Monad Control.Eff.Log.Writer.CaptureLogs
instance GHC.Base.Applicative Control.Eff.Log.Writer.CaptureLogs
instance GHC.Base.Functor Control.Eff.Log.Writer.CaptureLogs
instance GHC.Base.Monad Control.Eff.Log.Writer.PureLogWriter
instance GHC.Base.Applicative Control.Eff.Log.Writer.PureLogWriter
instance GHC.Base.Functor Control.Eff.Log.Writer.PureLogWriter
instance Data.OpenUnion.Member Control.Eff.Log.Writer.CapturedLogsWriter e => Control.Eff.Log.Writer.SupportsLogger Control.Eff.Log.Writer.CaptureLogs e
instance Control.Eff.Log.Writer.SupportsLogger Control.Eff.Log.Writer.PureLogWriter e
instance Control.Eff.Internal.Lifted GHC.Types.IO e => Control.Eff.Log.Writer.SupportsLogger GHC.Types.IO e
instance GHC.Base.Applicative w => Data.Default.Class.Default (Control.Eff.Log.Writer.LogWriter w)


-- | A memory efficient, streaming, logging effect with support for
--   efficiently not logging when no logs are required.
--   
--   Good support for logging to a file or to the network, as well as
--   asynchronous logging in another thread.
module Control.Eff.Log.Handler

-- | Log a message.
--   
--   All logging goes through this function.
--   
--   This function is the only place where the <a>LogPredicate</a> is
--   applied.
--   
--   Also, <a>LogMessage</a>s are evaluated using <a>deepseq</a>,
--   <b>after</b> they pass the <a>LogPredicate</a>.
logMsg :: forall e m. (HasCallStack, Member Logs e, ToLogMessage m) => m -> Eff e ()

-- | Log a <a>String</a> as <a>LogMessage</a> with a given <a>Severity</a>.
logWithSeverity :: forall e. (HasCallStack, Member Logs e) => Severity -> String -> Eff e ()

-- | Log a <a>String</a> as <a>emergencySeverity</a>.
logEmergency :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a message with <a>alertSeverity</a>.
logAlert :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>criticalSeverity</a> message.
logCritical :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>errorSeverity</a> message.
logError :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>warningSeverity</a> message.
logWarning :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>noticeSeverity</a> message.
logNotice :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>informationalSeverity</a> message.
logInfo :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Log a <a>debugSeverity</a> message.
logDebug :: forall e. (HasCallStack, Member Logs e) => String -> Eff e ()

-- | Include <a>LogMessage</a>s that match a <a>LogPredicate</a>.
--   
--   <tt>excludeLogMessages p</tt> allows log message to be logged if <tt>p
--   m</tt>
--   
--   Although it is enough if the previous predicate holds. See
--   <a>excludeLogMessages</a> and <a>modifyLogPredicate</a>.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
includeLogMessages :: forall e a. Member Logs e => LogPredicate -> Eff e a -> Eff e a

-- | Exclude <a>LogMessage</a>s that match a <a>LogPredicate</a>.
--   
--   <tt>excludeLogMessages p</tt> discards logs if <tt>p m</tt>
--   
--   Also the previous predicate must also hold for a message to be logged.
--   See <a>excludeLogMessages</a> and <a>modifyLogPredicate</a>.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
excludeLogMessages :: forall e a. Member Logs e => LogPredicate -> Eff e a -> Eff e a

-- | Keep only those messages, for which a predicate holds.
--   
--   E.g. to keep only messages which begin with <tt><a>OMG</a></tt>:
--   
--   <pre>
--   exampleLogPredicate :: IO Int
--   exampleLogPredicate =
--       runLift
--     $ withLogging consoleLogWriter
--     $ do logMsg "test"
--          setLogPredicate (\ msg -&gt; case view lmMessage msg of
--                                     'O':'M':'G':_ -&gt; True
--                                     _             -&gt; False)
--                            (do logMsg "this message will not be logged"
--                                logMsg "OMG logged"
--                                return 42)
--   </pre>
--   
--   In order to also delegate to the previous predicate, use
--   <a>modifyLogPredicate</a>
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
setLogPredicate :: forall r b. (Member Logs r, HasCallStack) => LogPredicate -> Eff r b -> Eff r b

-- | Change the <a>LogPredicate</a>.
--   
--   Other than <a>setLogPredicate</a> this function allows to include the
--   previous predicate, too.
--   
--   For to discard all messages currently no satisfying the predicate and
--   also all messages that are to long:
--   
--   <pre>
--   modifyLogPredicate (previousPredicate msg -&gt; previousPredicate msg &amp;&amp; length (lmMessage msg) &lt; 29 )
--                      (do logMsg "this message will not be logged"
--                          logMsg "this message might be logged")
--   </pre>
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
modifyLogPredicate :: forall e b. (Member Logs e, HasCallStack) => (LogPredicate -> LogPredicate) -> Eff e b -> Eff e b

-- | Get the current <a>Logs</a> filter/transformer function.
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
askLogPredicate :: forall e. Member Logs e => Eff e LogPredicate

-- | A Reader specialized for <a>LogWriter</a>s
--   
--   The existing <tt>Reader</tt> couldn't be used together with
--   <a>SetMember</a>, so this lazy reader was written, specialized to
--   reading <a>LogWriter</a>.
data LogWriterReader h v

-- | Replace the current <a>LogWriter</a>. To add an additional log message
--   consumer use <a>addLogWriter</a>
setLogWriter :: forall h e a. LogsTo h e => LogWriter h -> Eff e a -> Eff e a

-- | Combine the effects of a given <a>LogWriter</a> and the existing one.
--   
--   <pre>
--   exampleAddLogWriter :: IO ()
--   exampleAddLogWriter = go &gt;&gt;= putStrLn
--    where go = fmap (unlines . map renderLogMessage . snd)
--                 $  runLift
--                 $  runCapturedLogsWriter
--                 $  withLogging listLogWriter
--                 $  addLogWriter (mappingLogWriter (lmMessage %~ ("CAPTURED "++)) listLogWriter)
--                 $  addLogWriter (filteringLogWriter testPred (mappingLogWriter (lmMessage %~ ("TRACED "++)) debugTraceLogWriter))
--                 $  do
--                       logEmergency "test emergencySeverity 1"
--                       logCritical "test criticalSeverity 2"
--                       logAlert "test alertSeverity 3"
--                       logError "test errorSeverity 4"
--                       logWarning "test warningSeverity 5"
--                       logInfo "test informationalSeverity 6"
--                       logDebug "test debugSeverity 7"
--          testPred = view (lmSeverity . to (&lt;= errorSeverity))
--   </pre>
addLogWriter :: forall h e a. (HasCallStack, LogsTo h e, Monad h) => LogWriter h -> Eff e a -> Eff e a

-- | Open a file and add the <a>LogWriter</a> in the <a>LogWriterReader</a>
--   tha appends the log messages to it.
withLogFileAppender :: (Lifted IO e, LogsTo IO e, MonadBaseControl IO (Eff e)) => FilePath -> Eff e b -> Eff e b

-- | Modify the the <a>LogMessage</a>s written in the given sub-expression.
--   
--   Note: This is equivalent to <tt><a>modifyLogWriter</a> .
--   <a>mappingLogWriter</a></tt>
censorLogs :: LogsTo h e => (LogMessage -> LogMessage) -> Eff e a -> Eff e a

-- | Modify the the <a>LogMessage</a>s written in the given sub-expression,
--   as in <a>censorLogs</a> but with a effectful function.
--   
--   Note: This is equivalent to <tt><a>modifyLogWriter</a> .
--   <a>mappingLogWriterM</a></tt>
censorLogsM :: (LogsTo h e, Monad h) => (LogMessage -> h LogMessage) -> Eff e a -> Eff e a

-- | Get the current <a>LogWriter</a>.
askLogWriter :: SetMember LogWriterReader (LogWriterReader h) e => Eff e (LogWriter h)

-- | Change the current <a>LogWriter</a>.
modifyLogWriter :: forall h e a. LogsTo h e => (LogWriter h -> LogWriter h) -> Eff e a -> Eff e a

-- | This effect sends <a>LogMessage</a>s and is a reader for a
--   <a>LogPredicate</a>.
--   
--   Logs are sent via <a>logMsg</a>; for more informaion about log
--   predicates, see <a>Control.Eff.Log.Handler#LogPredicate</a>
--   
--   This effect is handled via <a>withLogging</a>.
data Logs v

-- | A constraint alias for effects that requires a <a>LogWriterReader</a>,
--   as well as that the contained <a>LogWriterReader</a> has a
--   <a>SupportsLogger</a> instance.
--   
--   The requirements of this constraint are provided by: *
--   <tt>withStdOutLogging</tt> * <a>withIoLogging</a> * <a>withLogging</a>
--   * <a>withSomeLogging</a>
type LogsTo h e = (Member Logs e, SupportsLogger h e, SetMember LogWriterReader (LogWriterReader h) e)

-- | Enable logging to <tt>stdout</tt> using the <a>defaultIoLogWriter</a>
--   in combination with the <a>consoleLogWriter</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithConsoleLogging :: IO ()
--   exampleWithConsoleLogging =
--       runLift
--     $ withConsoleLogging "my-app" local7 allLogMessages
--     $ logInfo "Oh, hi there"
--   </pre>
--   
--   To vary the <a>LogWriter</a> use <a>withIoLogging</a>.
withConsoleLogging :: SetMember Lift (Lift IO) e => String -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a

-- | Enable logging to IO using the <a>defaultIoLogWriter</a>.
--   
--   To log to the console (standard output), one can use
--   <a>withConsoleLogging</a>.
--   
--   Example:
--   
--   <pre>
--   exampleWithIoLogging :: IO ()
--   exampleWithIoLogging =
--       runLift
--     $ withIoLogging consoleLogWriter
--   </pre>
--   
--   "my-app" local7 (lmSeverityIsAtLeast informationalSeverity) &gt; $
--   logInfo "Oh, hi there"
withIoLogging :: SetMember Lift (Lift IO) e => LogWriter IO -> String -> Facility -> LogPredicate -> Eff (Logs : (LogWriterReader IO : e)) a -> Eff e a

-- | Handle the <a>Logs</a> and <a>LogWriterReader</a> effects.
--   
--   It installs the given <a>LogWriter</a>, which determines the
--   underlying <a>LogWriter</a> type parameter.
--   
--   Example:
--   
--   <pre>
--   exampleWithLogging :: IO ()
--   exampleWithLogging =
--       runLift
--     $ withLogging consoleLogWriter
--     $ logDebug "Oh, hi there"
--   </pre>
withLogging :: forall h e a. (Applicative h, LogsTo h (Logs : (LogWriterReader h : e))) => LogWriter h -> Eff (Logs : (LogWriterReader h : e)) a -> Eff e a

-- | Handles the <a>Logs</a> and <a>LogWriterReader</a> effects.
--   
--   By default it uses the <a>noOpLogWriter</a>, but using
--   <a>setLogWriter</a> the <a>LogWriter</a> can be replaced.
--   
--   This is like <a>withLogging</a> applied to <a>noOpLogWriter</a>
--   
--   Example:
--   
--   <pre>
--   exampleWithSomeLogging :: ()
--   exampleWithSomeLogging =
--       run
--     $ withSomeLogging @PureLogWriter
--     $ logDebug "Oh, hi there"
--   </pre>
withSomeLogging :: forall h e a. (Applicative h, LogsTo h (Logs : (LogWriterReader h : e))) => Eff (Logs : (LogWriterReader h : e)) a -> Eff e a

-- | The concrete list of <a>Eff</a>ects for logging with an IO based
--   <a>LogWriter</a>, and a <a>LogWriterReader</a>.
type LoggingAndIo = '[Logs, LogWriterReader IO, Lift IO]

-- | Raw handling of the <a>Logs</a> effect. Exposed for custom extensions,
--   if in doubt use <a>withLogging</a>.
runLogs :: forall h e b. (LogsTo h (Logs : e), SupportsLogger h (Logs : e)) => LogPredicate -> Eff (Logs : e) b -> Eff e b

-- | Consume log messages.
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
--   
--   Respond to all <a>LogMessage</a>s logged from the given action, up to
--   any <a>MonadBaseControl</a> liftings.
--   
--   Note that all logging is done through <a>logMsg</a> and that means
--   only messages passing the <a>LogPredicate</a> are received.
--   
--   The <a>LogMessage</a>s are <b>consumed</b> once they are passed to the
--   given callback function, previous <a>respondToLogMessage</a>
--   invocations further up in the call stack will not get the messages
--   anymore.
--   
--   Use <a>interceptLogMessages</a> if the messages shall be passed any
--   previous handler.
--   
--   NOTE: The effects of this function are <b>lost</b> when using
--   <a>MonadBaseControl</a>, <a>MonadMask</a>, <a>MonadCatch</a> and
--   <a>MonadThrow</a>.
--   
--   In contrast the functions based on modifying the <a>LogWriter</a>,
--   such as <a>addLogWriter</a> or <a>censorLogs</a>, are save to use in
--   combination with the aforementioned liftings.
respondToLogMessage :: forall r b. Member Logs r => (LogMessage -> Eff r ()) -> Eff r b -> Eff r b

-- | Change the <a>LogMessage</a>s using an effectful function.
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
--   
--   This differs from <a>respondToLogMessage</a> in that the intercepted
--   messages will be written either way, albeit in altered form.
--   
--   NOTE: The effects of this function are <b>lost</b> when using
--   <a>MonadBaseControl</a>, <a>MonadMask</a>, <a>MonadCatch</a> and
--   <a>MonadThrow</a>.
--   
--   In contrast the functions based on modifying the <a>LogWriter</a>,
--   such as <a>addLogWriter</a> or <a>censorLogs</a>, are save to use in
--   combination with the aforementioned liftings.
interceptLogMessages :: forall r b. Member Logs r => (LogMessage -> Eff r LogMessage) -> Eff r b -> Eff r b

-- | Provide the <a>LogWriter</a>
--   
--   Exposed for custom extensions, if in doubt use <a>withLogging</a>.
runLogWriterReader :: LogWriter h -> Eff (LogWriterReader h : e) a -> Eff e a
instance (Control.Monad.Base.MonadBase m m, Control.Eff.Internal.LiftedBase m e, Control.Eff.Log.Writer.SupportsLogger m (Control.Eff.Log.Handler.Logs : e), Data.OpenUnion.SetMember Control.Eff.Log.Handler.LogWriterReader (Control.Eff.Log.Handler.LogWriterReader m) (Control.Eff.Log.Handler.Logs : e)) => Control.Monad.Trans.Control.MonadBaseControl m (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e), Control.Eff.Log.Writer.SupportsLogger m (Control.Eff.Log.Handler.Logs : e), Data.OpenUnion.SetMember Control.Eff.Log.Handler.LogWriterReader (Control.Eff.Log.Handler.LogWriterReader m) (Control.Eff.Log.Handler.Logs : e)) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e), Control.Eff.Log.Writer.SupportsLogger m (Control.Eff.Log.Handler.Logs : e), Data.OpenUnion.SetMember Control.Eff.Log.Handler.LogWriterReader (Control.Eff.Log.Handler.LogWriterReader m) (Control.Eff.Log.Handler.Logs : e)) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))
instance Control.Eff.Internal.Handle (Control.Eff.Log.Handler.LogWriterReader h) e a (Control.Eff.Log.Writer.LogWriter h -> k)
instance (Control.Monad.Base.MonadBase m m, Control.Eff.Internal.LiftedBase m r) => Control.Monad.Trans.Control.MonadBaseControl m (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.LogWriterReader h : r))
instance (Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.LogWriterReader h : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadCatch (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.LogWriterReader h : e))
instance (GHC.Base.Applicative m, Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadMask (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.LogWriterReader h : e))
instance Control.Eff.Internal.Handle Control.Eff.Log.Handler.Logs e a (Control.Eff.Log.Message.LogPredicate -> k)
instance (Control.Eff.Internal.LiftedBase m e, Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff e)) => Control.Monad.Catch.MonadThrow (Control.Eff.Internal.Eff (Control.Eff.Log.Handler.Logs : e))


-- | The message passing effect.
--   
--   This module describes an abstract message passing effect, and a
--   process effect, mimicking Erlang's process and message semantics.
--   
--   Two <b>scheduler</b> implementations for the <a>Process</a> effect are
--   provided:
--   
--   <ul>
--   <li>A scheduler using <tt>forkIO</tt>, i.e. relying on the multi
--   threaded GHC runtime:
--   <a>Control.Eff.Concurrent.Process.ForkIOScheduler</a></li>
--   <li>And a <i>pure</i>(rer) coroutine based scheduler in:
--   <a>Control.Eff.Concurrent.Process.SingleThreadedScheduler</a></li>
--   </ul>
module Control.Eff.Concurrent.Process

-- | The process effect is the basis for message passing concurrency. This
--   effect describes an interface for concurrent, communicating isolated
--   processes identified uniquely by a process-id.
--   
--   Processes can raise exceptions that can be caught, exit gracefully or
--   with an error, or be killed by other processes, with the option of
--   ignoring the shutdown request.
--   
--   Process Scheduling is implemented in different modules. All scheduler
--   implementations should follow some basic rules:
--   
--   <ul>
--   <li>fair scheduling</li>
--   <li>sending a message does not block</li>
--   <li>receiving a message does block</li>
--   <li>spawning a child blocks only a very moment</li>
--   <li>a newly spawned process shall be scheduled before the parent
--   process after</li>
--   <li>the spawnRaw</li>
--   <li>when the first process exists, all process should be killed
--   immediately</li>
--   </ul>
data Process (r :: [Type -> Type]) b

-- | Remove all messages from the process' message queue
[FlushMessages] :: Process r (ResumeProcess [Dynamic])

-- | In cooperative schedulers, this will give processing time to the
--   scheduler. Every other operation implicitly serves the same purpose.
[YieldProcess] :: Process r (ResumeProcess ())

-- | Return the current <a>ProcessId</a>
[SelfPid] :: Process r (ResumeProcess ProcessId)

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>.
[Spawn] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Start a new process, and <a>Link</a> to it .
[SpawnLink] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Get the process state (or <a>Nothing</a> if the process is dead)
[GetProcessState] :: ProcessId -> Process r (ResumeProcess (Maybe ProcessState))

-- | Shutdown the process; irregardless of the exit reason, this function
--   never returns,
[Shutdown] :: ExitReason  'NoRecovery -> Process r a

-- | Raise an error, that can be handled.
[SendShutdown] :: ProcessId -> ExitReason  'NoRecovery -> Process r (ResumeProcess ())

-- | Request that another a process interrupts. The targeted process is
--   interrupted and gets an <a>Interrupted</a>, the target process may
--   decide to ignore the interrupt and continue as if nothing happened.
[SendInterrupt] :: ProcessId -> InterruptReason -> Process r (ResumeProcess ())

-- | Send a message to a process addressed by the <a>ProcessId</a>. Sending
--   a message should <b>always succeed</b> and return <b>immediately</b>,
--   even if the destination process does not exist, or does not accept
--   messages of the given type.
[SendMessage] :: ProcessId -> Dynamic -> Process r (ResumeProcess ())

-- | Receive a message that matches a criteria. This should block until an
--   a message was received. The message is returned as a
--   <a>ResumeProcess</a> value. The function should also return if an
--   exception was caught or a shutdown was requested.
[ReceiveSelectedMessage] :: forall r a. MessageSelector a -> Process r (ResumeProcess a)

-- | Generate a unique <a>Int</a> for the current process.
[MakeReference] :: Process r (ResumeProcess Int)

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
[Monitor] :: ProcessId -> Process r (ResumeProcess MonitorReference)

-- | Remove a monitor.
[Demonitor] :: MonitorReference -> Process r (ResumeProcess ())

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>ExitReason</a>
--   <a>LinkedProcessCrashed</a>.
[Link] :: ProcessId -> Process r (ResumeProcess ())

-- | Unlink the calling process from the other process.
[Unlink] :: ProcessId -> Process r (ResumeProcess ())

-- | Each process is identified by a single process id, that stays constant
--   throughout the life cycle of a process. Also, message sending relies
--   on these values to address messages to processes.
newtype ProcessId
ProcessId :: Int -> ProcessId
[_fromProcessId] :: ProcessId -> Int
fromProcessId :: Iso' ProcessId Int

-- | <i>Cons</i> <a>Process</a> onto a list of effects.
type ConsProcess r = Process r : r

-- | Every <a>Process</a> action returns it's actual result wrapped in this
--   type. It will allow to signal errors as well as pass on normal results
--   such as incoming messages.
data ResumeProcess v

-- | The current operation of the process was interrupted with a
--   <a>ExitReason</a>. If <a>isRecoverable</a> holds for the given reason,
--   the process may choose to continue.
[Interrupted] :: InterruptReason -> ResumeProcess v

-- | The process may resume to do work, using the given result.
[ResumeWith] :: a -> ResumeProcess a

-- | Every function for <a>Process</a> things needs such a proxy value for
--   the low-level effect list, i.e. the effects identified by
--   <tt><b>r</b></tt> in <tt><a>Process</a> r : r</tt>, this might be
--   dependent on the scheduler implementation.
data SchedulerProxy :: [Type -> Type] -> Type

-- | Tell the type checker what effects we have below <a>Process</a>
[SchedulerProxy] :: SchedulerProxy q

-- | Like <a>SchedulerProxy</a> but shorter
[SP] :: SchedulerProxy q

-- | Like <a>SP</a> but different
[Scheduler] :: SchedulerProxy q

-- | Return a <a>SchedulerProxy</a> for a <a>Process</a> effect.
thisSchedulerProxy :: Eff (Process r : r) (SchedulerProxy r)

-- | The state that a <a>Process</a> is currently in.
data ProcessState

-- | The process has just been started but not scheduled yet.
ProcessBooting :: ProcessState

-- | The process yielded it's time slice
ProcessIdle :: ProcessState

-- | The process is busy with non-blocking
ProcessBusy :: ProcessState

-- | The process is busy with sending a message
ProcessBusySending :: ProcessState

-- | The process is busy with killing
ProcessBusySendingShutdown :: ProcessState

-- | The process is busy with killing
ProcessBusySendingInterrupt :: ProcessState

-- | The process blocked by a <a>receiveAnyMessage</a>
ProcessBusyReceiving :: ProcessState

-- | The process blocked by a <a>linkProcess</a>
ProcessBusyLinking :: ProcessState

-- | The process blocked by a <a>unlinkProcess</a>
ProcessBusyUnlinking :: ProcessState

-- | The process blocked by a <a>monitor</a>
ProcessBusyMonitoring :: ProcessState

-- | The process blocked by a <a>demonitor</a>
ProcessBusyDemonitoring :: ProcessState

-- | The process was interrupted
ProcessInterrupted :: ProcessState

-- | The process was shutdown or crashed
ProcessShuttingDown :: ProcessState

-- | Use <a>executeAndResumeOrExit</a> to execute <a>YieldProcess</a>.
--   Refer to <a>YieldProcess</a> for more information.
yieldProcess :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Eff r ()

-- | Send a message to a process addressed by the <a>ProcessId</a>. See
--   <a>SendMessage</a>.
sendMessage :: forall r q o. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o) => ProcessId -> o -> Eff r ()

-- | Send a <a>Dynamic</a> value to a process addressed by the
--   <a>ProcessId</a>. See <a>SendMessage</a>.
sendAnyMessage :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> Dynamic -> Eff r ()

-- | Exit a process addressed by the <a>ProcessId</a>. The process will
--   exit, it might do some cleanup, but is ultimately unrecoverable. See
--   <a>SendShutdown</a>.
sendShutdown :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> ExitReason  'NoRecovery -> Eff r ()

-- | Interrupts a process addressed by the <a>ProcessId</a>. The process
--   might exit, or it may continue. | Like <a>sendInterrupt</a>, but also
--   return <tt>True</tt> iff the process to exit exists.
sendInterrupt :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> InterruptReason -> Eff r ()

-- | Generate a unique <a>Int</a> for the current process.
makeReference :: (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r Int

-- | Receive and cast the message to some <a>Typeable</a> instance. See
--   <a>ReceiveSelectedMessage</a> for more documentation. This will wait
--   for a message of the return type using <a>receiveSelectedMessage</a>
receiveMessage :: forall a r q. (HasCallStack, Typeable a, Show a, SetMember Process (Process q) r, Member Interrupts r) => Eff r a

-- | Block until a message was received, that is not <a>Nothing</a> after
--   applying a callback to it. See <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedMessage :: forall r q a. (HasCallStack, Show a, SetMember Process (Process q) r, Member Interrupts r) => MessageSelector a -> Eff r a

-- | Remove and return all messages currently enqueued in the process
--   message queue.
flushMessages :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r [Dynamic]

-- | Block until a message was received. See <a>ReceiveSelectedMessage</a>
--   for more documentation.
receiveAnyMessage :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r Dynamic

-- | Like <a>receiveSelectedLoop</a> but refined to casting to a specific
--   <a>Typeable</a> using <a>selectMessageLazy</a>.
receiveLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack, Typeable a) => (Either InterruptReason a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Enter a loop to receive messages and pass them to a callback, until
--   the function returns <a>Just</a> a result. Only the messages of the
--   given type will be received. If the process is interrupted by an
--   exception of by a <a>SendShutdown</a> from another process, with an
--   exit reason that satisfies <a>isRecoverable</a>, then the callback
--   will be invoked with <tt><a>Left</a> <a>ExitReason</a></tt>, otherwise
--   the process will be exited with the same reason using
--   <a>exitBecause</a>. See also <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => MessageSelector a -> (Either InterruptReason a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Like <a>receiveSelectedLoop</a> but <i>not selective</i>. See also
--   <a>selectAnyMessageLazy</a>, <a>receiveSelectedLoop</a>.
receiveAnyLoop :: forall r q endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => (Either InterruptReason Dynamic -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | A function that decided if the next message will be received by
--   <a>ReceiveSelectedMessage</a>. It conveniently is an instance of
--   <a>Alternative</a> so the message selector can be combined: &gt; &gt;
--   selectInt :: MessageSelector Int &gt; selectInt = selectMessage &gt;
--   &gt; selectString :: MessageSelector String &gt; selectString =
--   selectMessage &gt; &gt; selectIntOrString :: MessageSelector (Either
--   Int String) &gt; selectIntOrString = &gt; Left <a>$</a>
--   selectTimeout<a>|</a> Right <a>$</a> selectString
data MessageSelector a

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a>. It will also <a>force</a> the result.
selectMessage :: (NFData t, Typeable t) => MessageSelector t

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a>. It will also <a>force</a> the result.
selectMessageLazy :: Typeable t => MessageSelector t

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a> with a proxy argument. It will also <a>force</a>
--   the result.
selectMessageProxy :: forall proxy t. (NFData t, Typeable t) => proxy t -> MessageSelector t

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a> with a proxy argument. It will also <a>force</a>
--   the result.
selectMessageProxyLazy :: forall proxy t. Typeable t => proxy t -> MessageSelector t

-- | Create a message selector from a predicate. It will <a>force</a> the
--   result.
filterMessage :: (Typeable a, NFData a) => (a -> Bool) -> MessageSelector a

-- | Create a message selector from a predicate. It will <a>force</a> the
--   result.
filterMessageLazy :: Typeable a => (a -> Bool) -> MessageSelector a

-- | Select a message of type <tt>a</tt> and apply the given function to
--   it. If the function returns <a>Just</a> The
--   <a>ReceiveSelectedMessage</a> function will return the result (sans
--   <tt>Maybe</tt>). It will <a>force</a> the result.
selectMessageWith :: (Typeable a, NFData b) => (a -> Maybe b) -> MessageSelector b

-- | Select a message of type <tt>a</tt> and apply the given function to
--   it. If the function returns <a>Just</a> The
--   <a>ReceiveSelectedMessage</a> function will return the result (sans
--   <tt>Maybe</tt>). It will <a>force</a> the result.
selectMessageWithLazy :: Typeable a => (a -> Maybe b) -> MessageSelector b

-- | Create a message selector. It will <a>force</a> the result.
selectDynamicMessage :: NFData a => (Dynamic -> Maybe a) -> MessageSelector a

-- | Create a message selector.
selectDynamicMessageLazy :: (Dynamic -> Maybe a) -> MessageSelector a

-- | Create a message selector that will match every message. This is
--   <i>lazy</i> because the result is not <a>force</a>ed.
selectAnyMessageLazy :: MessageSelector Dynamic

-- | Returns the <a>ProcessId</a> of the current process.
self :: (HasCallStack, SetMember Process (Process q) r) => Eff r ProcessId

-- | Return <a>True</a> if the process is alive.
isProcessAlive :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r Bool

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. If the new
--   process is interrupted, the process will <a>Shutdown</a> with the
--   <a>InterruptReason</a> wrapped in <a>NotRecovered</a>. For specific
--   use cases it might be better to use <a>spawnRaw</a>.
spawn :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Like <a>spawn</a> but return <tt>()</tt>.
spawn_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ()

-- | Start a new process, and immediately link to it.
spawnLink :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. The spawned
--   process has only the <i>raw</i> <a>ConsProcess</a> effects. For
--   non-library code <a>spawn</a> might be better suited.
spawnRaw :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ProcessId

-- | Like <a>spawnRaw</a> but return <tt>()</tt>.
spawnRaw_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ()

-- | Exit the process with a <a>ExitReason</a>.
exitBecause :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => ExitReason  'NoRecovery -> Eff r a

-- | Exit the process.
exitNormally :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => Eff r a

-- | Exit the process with an error.
exitWithError :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => String -> Eff r a

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>ExitReason</a>
--   <a>LinkedProcessCrashed</a>.
linkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Unlink the calling process from the other process.
unlinkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
monitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r MonitorReference

-- | Remove a monitor created with <a>monitor</a>.
demonitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => MonitorReference -> Eff r ()

-- | A monitored process exited. This message is sent to a process by the
--   scheduler, when a process that was monitored died.
data ProcessDown
ProcessDown :: !MonitorReference -> !SomeExitReason -> ProcessDown
[downReference] :: ProcessDown -> !MonitorReference
[downReason] :: ProcessDown -> !SomeExitReason

-- | A <a>MessageSelector</a> for the <a>ProcessDown</a> message of a
--   specific process.
selectProcessDown :: MonitorReference -> MessageSelector ProcessDown

-- | Make an <a>InterruptReason</a> for a <a>ProcessDown</a> message.
--   
--   For example: <tt>doSomething &gt;&gt;= either (interrupt .
--   becauseProcessIsDown) return</tt>
becauseProcessIsDown :: ProcessDown -> InterruptReason

-- | A value that contains a unique reference of a process monitoring.
data MonitorReference
MonitorReference :: Int -> ProcessId -> MonitorReference
[monitorIndex] :: MonitorReference -> Int
[monitoredProcess] :: MonitorReference -> ProcessId

-- | <a>monitor</a> another process before while performing an action and
--   <a>demonitor</a> afterwards.
withMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> (MonitorReference -> Eff r a) -> Eff r a

-- | A <a>MessageSelector</a> for receiving either a monitor of the given
--   process or another message.
receiveWithMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r, Typeable a, Show a) => ProcessId -> MessageSelector a -> Eff r (Either ProcessDown a)

-- | Handle all <a>InterruptReason</a>s of an <a>InterruptableProcess</a>
--   by wrapping them up in <a>NotRecovered</a> and then do a process
--   <a>Shutdown</a>.
provideInterruptsShutdown :: forall e a. Eff (InterruptableProcess e) a -> Eff (ConsProcess e) a

-- | Handle <a>InterruptReason</a>s arising during process operations, e.g.
--   when a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
handleInterrupts :: (HasCallStack, Member Interrupts r) => (InterruptReason -> Eff r a) -> Eff r a -> Eff r a

-- | Like <a>handleInterrupts</a>, but instead of passing the
--   <a>InterruptReason</a> to a handler function, <a>Either</a> is
--   returned.
tryUninterrupted :: (HasCallStack, Member Interrupts r) => Eff r a -> Eff r (Either InterruptReason a)

-- | Handle <a>InterruptReason</a>s arising during process operations, e.g.
--   when a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
exitOnInterrupt :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r) => Eff r a -> Eff r a

-- | Handle interrupts by logging them with <a>logProcessExit</a> and
--   otherwise ignoring them.
logInterrupts :: forall r. (Member Logs r, HasCallStack, Member Interrupts r) => Eff r () -> Eff r ()

-- | Handle <a>InterruptReason</a>s arising during process operations, e.g.
--   when a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
provideInterrupts :: HasCallStack => Eff (Interrupts : r) a -> Eff r (Either InterruptReason a)

-- | Wrap all (left) <a>InterruptReason</a>s into <a>NotRecovered</a> and
--   return the (right) <a>NoRecovery</a> <a>ExitReason</a>s as is.
mergeEitherInterruptAndExitReason :: Either InterruptReason (ExitReason  'NoRecovery) -> ExitReason  'NoRecovery

-- | Throw an <a>InterruptReason</a>, can be handled by
--   <a>handleInterrupts</a> or <a>exitOnInterrupt</a> or
--   <a>provideInterrupts</a>.
interrupt :: (HasCallStack, Member Interrupts r) => InterruptReason -> Eff r a

-- | Execute a and action and return the result; if the process is
--   interrupted by an error or exception, or an explicit shutdown from
--   another process, or through a crash of a linked process, i.e. whenever
--   the exit reason satisfies <a>isRecoverable</a>, return the exit
--   reason.
executeAndResume :: forall q r v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r (Either (ExitReason  'Recoverable) v)

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrExit :: forall r q v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r v

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrThrow :: forall q r v. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Process q (ResumeProcess v) -> Eff r v

-- | A sum-type with reasons for why a process exists the scheduling loop,
--   this includes errors, that can occur when scheduling messages.
data ExitReason (t :: ExitRecovery)

-- | A process has finished a unit of work and might exit or work on
--   something else. This is primarily used for interrupting infinite
--   server loops, allowing for additional cleanup work before exiting
--   (e.g. with <a>ExitNormally</a>)
[ProcessFinished] :: ExitReason  'Recoverable

-- | A process that should be running was not running.
[ProcessNotRunning] :: ProcessId -> ExitReason  'Recoverable

-- | A linked process is down
[LinkedProcessCrashed] :: ProcessId -> ExitReason  'Recoverable

-- | An exit reason that has an error message but isn't <a>Recoverable</a>.
[ProcessError] :: String -> ExitReason  'Recoverable

-- | A process function returned or exited without any error.
[ExitNormally] :: ExitReason  'NoRecovery

-- | An unhandled <a>Recoverable</a> allows <a>NoRecovery</a>.
[NotRecovered] :: ExitReason  'Recoverable -> ExitReason  'NoRecovery

-- | An unexpected runtime exception was thrown, i.e. an exception derived
--   from <a>SomeException</a>
[UnexpectedException] :: String -> String -> ExitReason  'NoRecovery

-- | A process was cancelled (e.g. killed, in <a>cancel</a>)
[Killed] :: ExitReason  'NoRecovery

-- | This kind is used to indicate if a <a>ExitReason</a> can be treated
--   like a short interrupt which can be handled or ignored.
data ExitRecovery
Recoverable :: ExitRecovery
NoRecovery :: ExitRecovery

-- | <a>ExitReason</a>s which are recoverable are interrupts.
type InterruptReason = ExitReason  'Recoverable

-- | <a>Exc</a>eptions containing <a>InterruptReason</a>s. See
--   <a>handleInterrupts</a>, <a>exitOnInterrupt</a> or
--   <a>provideInterrupts</a>
type Interrupts = Exc InterruptReason

-- | This adds a layer of the <a>Interrupts</a> effect on top of
--   <a>ConsProcess</a>
type InterruptableProcess e = Interrupts : ConsProcess e

-- | This value indicates whether a process exited in way consistent with
--   the planned behaviour or not.
data ExitSeverity
NormalExit :: ExitSeverity
Crash :: ExitSeverity

-- | An existential wrapper around <a>ExitReason</a>
data SomeExitReason
[SomeExitReason] :: ExitReason x -> SomeExitReason

-- | Get the <a>ExitRecovery</a>
toExitRecovery :: ExitReason r -> ExitRecovery

-- | A predicate for recoverable exit reasons. This predicate defines the
--   exit reasons which functions such as <a>executeAndResume</a>
isRecoverable :: ExitReason x -> Bool

-- | Get the <a>ExitSeverity</a> of a <a>ExitReason</a>.
toExitSeverity :: ExitReason e -> ExitSeverity

-- | A predicate for linked process <b>crashes</b>.
isBecauseDown :: Maybe ProcessId -> ExitReason r -> Bool

-- | A predicate for crashes. A <i>crash</i> happens when a process exits
--   with an <a>ExitReason</a> other than <a>ExitNormally</a>
isCrash :: ExitReason x -> Bool

-- | Print a <a>ExitReason</a> to <a>Just</a> a formatted <a>String</a>
--   when <a>isCrash</a> is <a>True</a>. This can be useful in combination
--   with view patterns, e.g.:
--   
--   <pre>
--   logCrash :: ExitReason -&gt; Eff e ()
--   logCrash (toCrashReason -&gt; Just reason) = logError reason
--   logCrash _ = return ()
--   </pre>
--   
--   Though this can be improved to:
--   
--   <pre>
--   logCrash = traverse_ logError . toCrashReason
--   </pre>
toCrashReason :: ExitReason x -> Maybe String

-- | Partition a <a>SomeExitReason</a> back into either a <a>NoRecovery</a>
--   or a <a>Recoverable</a> <a>ExitReason</a>
fromSomeExitReason :: SomeExitReason -> Either (ExitReason  'NoRecovery) InterruptReason

-- | Log the <a>ExitReason</a>s
logProcessExit :: forall e x. (Member Logs e, HasCallStack) => ExitReason x -> Eff e ()
instance GHC.Show.Show v => GHC.Show.Show (Control.Eff.Concurrent.Process.ResumeProcess v)
instance GHC.Generics.Generic1 Control.Eff.Concurrent.Process.ResumeProcess
instance GHC.Generics.Generic (Control.Eff.Concurrent.Process.ResumeProcess v)
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Read.Read Control.Eff.Concurrent.Process.MonitorReference
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ProcessId
instance GHC.Real.Real Control.Eff.Concurrent.Process.ProcessId
instance GHC.Real.Integral Control.Eff.Concurrent.Process.ProcessId
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.ProcessId
instance GHC.Num.Num Control.Eff.Concurrent.Process.ProcessId
instance GHC.Enum.Bounded Control.Eff.Concurrent.Process.ProcessId
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ProcessId
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ProcessId
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ExitSeverity
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ExitSeverity
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ExitSeverity
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Generics.Generic Control.Eff.Concurrent.Process.ProcessState
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.ProcessState
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.ProcessState
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.ProcessState
instance GHC.Show.Show Control.Eff.Concurrent.Process.ProcessState
instance GHC.Read.Read Control.Eff.Concurrent.Process.ProcessState
instance GHC.Base.Functor Control.Eff.Concurrent.Process.MessageSelector
instance GHC.Base.Semigroup a => GHC.Base.Monoid (Control.Eff.Concurrent.Process.MessageSelector a)
instance GHC.Base.Semigroup a => GHC.Base.Semigroup (Control.Eff.Concurrent.Process.MessageSelector a)
instance GHC.Show.Show (Control.Eff.Concurrent.Process.Process r b)
instance Control.DeepSeq.NFData a => Control.DeepSeq.NFData (Control.Eff.Concurrent.Process.ResumeProcess a)
instance Control.DeepSeq.NFData1 Control.Eff.Concurrent.Process.ResumeProcess
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Show.Show Control.Eff.Concurrent.Process.ProcessDown
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.SomeExitReason
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.SomeExitReason
instance GHC.Show.Show Control.Eff.Concurrent.Process.SomeExitReason
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.SomeExitReason
instance GHC.Show.Show (Control.Eff.Concurrent.Process.ExitReason x)
instance GHC.Exception.Type.Exception (Control.Eff.Concurrent.Process.ExitReason 'Control.Eff.Concurrent.Process.Recoverable)
instance GHC.Exception.Type.Exception (Control.Eff.Concurrent.Process.ExitReason 'Control.Eff.Concurrent.Process.NoRecovery)
instance Control.DeepSeq.NFData (Control.Eff.Concurrent.Process.ExitReason x)
instance GHC.Classes.Ord (Control.Eff.Concurrent.Process.ExitReason x)
instance GHC.Classes.Eq (Control.Eff.Concurrent.Process.ExitReason x)
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Show.Show Control.Eff.Concurrent.Process.MonitorReference
instance GHC.Read.Read Control.Eff.Concurrent.Process.ProcessId
instance GHC.Show.Show Control.Eff.Concurrent.Process.ProcessId
instance GHC.Show.Show Control.Eff.Concurrent.Process.ExitSeverity
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ExitSeverity
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ExitRecovery
instance GHC.Show.Show Control.Eff.Concurrent.Process.ExitRecovery
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.ProcessState
instance Data.Default.Class.Default Control.Eff.Concurrent.Process.ProcessState
instance GHC.Base.Applicative Control.Eff.Concurrent.Process.MessageSelector
instance GHC.Base.Alternative Control.Eff.Concurrent.Process.MessageSelector


-- | Functions for timeouts when receiving messages.
--   
--   NOTE: If you use a single threaded scheduler, these functions will not
--   work as expected. (This is an open TODO)
module Control.Eff.Concurrent.Process.Timer

-- | A number of micro seconds.
data Timeout

-- | The reference to a timer started by <a>startTimer</a>, required to
--   stop a timer via <a>cancelTimer</a>.
data TimerReference

-- | A value to be sent when timer started with <a>startTimer</a> has
--   elapsed.
data TimerElapsed

-- | Send a message to a given process after waiting. The message is
--   created by applying the function parameter to the
--   <a>TimerReference</a>, such that the message can directly refer to the
--   timer.
sendAfter :: forall r q message. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable message, NFData message) => ProcessId -> Timeout -> (TimerReference -> message) -> Eff r TimerReference

-- | Start a new timer, after the time has elapsed, <a>TimerElapsed</a> is
--   sent to calling process. The message also contains the
--   <a>TimerReference</a> returned by this function. Use
--   <a>cancelTimer</a> to cancel the timer. Use <a>selectTimerElapsed</a>
--   to receive the message using <a>receiveSelectedMessage</a>. To receive
--   messages with guarded with a timeout see <a>receiveAfter</a>.
startTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Timeout -> Eff r TimerReference

-- | Cancel a timer started with <a>startTimer</a>.
cancelTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => TimerReference -> Eff r ()

-- | A <a>MessageSelector</a> matching <a>TimerElapsed</a> messages created
--   by <a>startTimer</a>.
selectTimerElapsed :: TimerReference -> MessageSelector TimerElapsed

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Nothing</a>. This is based on
--   <a>receiveSelectedAfter</a>.
receiveAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable a, NFData a, Show a) => Timeout -> Eff r (Maybe a)

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Left</a> <a>TimerElapsed</a>. This
--   is based on <a>selectTimerElapsed</a> and <a>startTimer</a>.
receiveSelectedAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Show a) => MessageSelector a -> Timeout -> Eff r (Either TimerElapsed a)
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Real.Real Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Real.Integral Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Num.Num Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.Timer.TimerReference
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Enum.Enum Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Real.Real Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Real.Integral Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Num.Num Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Classes.Eq Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Classes.Ord Control.Eff.Concurrent.Process.Timer.Timeout
instance Control.DeepSeq.NFData Control.Eff.Concurrent.Process.Timer.Timeout
instance GHC.Show.Show Control.Eff.Concurrent.Process.Timer.TimerElapsed
instance GHC.Show.Show Control.Eff.Concurrent.Process.Timer.TimerReference
instance GHC.Show.Show Control.Eff.Concurrent.Process.Timer.Timeout


-- | This module contains a mechanism to specify what kind of messages (aka
--   <i>requests</i>) a <a>Server</a> (<a>Process</a>) can handle, and if
--   the caller blocks and waits for an answer, which the server process
--   provides.
--   
--   The type magic in the <a>Api</a> type familiy allows to define a
--   related set of <i>requests</i> along with the corresponding responses.
--   
--   Request handling can be either blocking, if a response is requred, or
--   non-blocking.
--   
--   A process can <i>serve</i> a specific <a>Api</a> instance by using the
--   functions provided by the <a>Control.Eff.Concurrent.Api.Server</a>
--   module.
--   
--   To enable a process to use such a <i>service</i>, the functions
--   provided by the <a>Control.Eff.Concurrent.Api.Client</a> should be
--   used.
module Control.Eff.Concurrent.Api

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)

-- | The (promoted) constructors of this type specify (at the type level)
--   the reply behavior of a specific constructor of an <tt>Api</tt>
--   instance.
data Synchronicity

-- | Specify that handling a request is a blocking operation with a
--   specific return type, e.g. <tt>('Synchronous (Either RentalError
--   RentalId))</tt>
Synchronous :: Type -> Synchronicity

-- | Non-blocking, asynchronous, request handling
Asynchronous :: Synchronicity

-- | This is a tag-type that wraps around a <a>ProcessId</a> and holds an
--   <a>Api</a> index type.
newtype Server api
Server :: ProcessId -> Server api
[_fromServer] :: Server api -> ProcessId
fromServer :: forall api_aSTl api_aT2L. Iso (Server api_aSTl) (Server api_aT2L) ProcessId ProcessId

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
proxyAsServer :: proxy api -> ProcessId -> Server api

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
asServer :: forall api. ProcessId -> Server api
instance forall k (api :: k). GHC.Classes.Ord (Control.Eff.Concurrent.Api.Server api)
instance forall k (api :: k). GHC.Classes.Eq (Control.Eff.Concurrent.Api.Server api)
instance forall k (api :: k). Data.Typeable.Internal.Typeable api => GHC.Show.Show (Control.Eff.Concurrent.Api.Server api)


-- | Functions for <a>Api</a> clients.
--   
--   This modules is required to write clients that consume an <a>Api</a>.
module Control.Eff.Concurrent.Api.Client

-- | Send an <a>Api</a> request that has no return value and return as fast
--   as possible. The type signature enforces that the corresponding
--   <a>Api</a> clause is <a>Asynchronous</a>. The operation never fails,
--   if it is important to know if the message was delivered, use
--   <a>call</a> instead.
cast :: forall r q o. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable o, Typeable (Api o  'Asynchronous)) => Server o -> Api o  'Asynchronous -> Eff r ()

-- | Send an <a>Api</a> request and wait for the server to return a result
--   value.
--   
--   The type signature enforces that the corresponding <a>Api</a> clause
--   is <a>Synchronous</a>.
call :: forall result api r q. (SetMember Process (Process q) r, Member Interrupts r, Typeable api, Typeable (Api api ( 'Synchronous result)), Typeable result, HasCallStack, NFData result, Show result) => Server api -> Api api ( 'Synchronous result) -> Eff r result

-- | Like <a>cast</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
castRegistered :: (Typeable o, ServesApi o r q, HasCallStack, Member Interrupts r) => Api o  'Asynchronous -> Eff r ()

-- | Like <a>call</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
callRegistered :: (Typeable reply, ServesApi o r q, HasCallStack, NFData reply, Show reply, Member Interrupts r) => Api o ( 'Synchronous reply) -> Eff r reply

-- | Instead of passing around a <a>Server</a> value and passing to
--   functions like <a>cast</a> or <a>call</a>, a <a>Server</a> can
--   provided by a <a>Reader</a> effect, if there is only a <b>single
--   server</b> for a given <a>Api</a> instance. This type alias is
--   convenience to express that an effect has <a>Process</a> and a reader
--   for a <a>Server</a>.
type ServesApi o r q = (Typeable o, SetMember Process (Process q) r, Member (ServerReader o) r)

-- | The reader effect for <a>ProcessId</a>s for <a>Api</a>s, see
--   <a>registerServer</a>
type ServerReader o = Reader (Server o)

-- | Get the <a>Server</a> registered with <a>registerServer</a>.
whereIsServer :: Member (ServerReader o) e => Eff e (Server o)

-- | Run a reader effect that contains <b>the one</b> server handling a
--   specific <a>Api</a> instance.
registerServer :: HasCallStack => Server o -> Eff (ServerReader o : r) a -> Eff r a


-- | This module provides support for executing <a>Process</a> actions from
--   <a>IO</a>.
--   
--   One use case is interacting with processes from the REPL, e.g.:
--   
--   <pre>
--   &gt;&gt;&gt; import Control.Eff.Concurrent.Process.SingleThreadedScheduler (defaultMain)
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; import Control.Eff.Loop
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; import Data.Dynamic
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; import Data.Maybe
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; s &lt;- forkInteractiveScheduler Control.Eff.Concurrent.Process.SingleThreadedScheduler.defaultMain
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; fooPid &lt;- submit s (spawn (foreverCheap (receiveAnyMessage SP &gt;&gt;= (logMsg . fromMaybe "Huh!??" . fromDynamic))))
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; fooPid
--   &lt;0.1.0&gt;
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; submit s (sendMessageAs SP fooPid "test")
--   test
--   </pre>
--   
--   <pre>
--   &gt;&gt;&gt; submit s (sendShutdown SP fooPid)
--   </pre>
module Control.Eff.Concurrent.Process.Interactive

-- | Contains the communication channels to interact with a scheduler
--   running in its' own thread.
data SchedulerSession r

-- | Fork a scheduler with a process that communicates with it via
--   <a>MVar</a>, which is also the reason for the <tt>Lift IO</tt>
--   constraint.
forkInteractiveScheduler :: forall r. SetMember Lift (Lift IO) r => (Eff (InterruptableProcess r) () -> IO ()) -> IO (SchedulerSession r)

-- | Exit the schedulder immediately using an asynchronous exception.
killInteractiveScheduler :: SchedulerSession r -> IO ()

-- | Send a <a>Process</a> effect to the main process of a scheduler, this
--   blocks until the effect is executed.
submit :: forall r a. SetMember Lift (Lift IO) r => SchedulerSession r -> Eff (InterruptableProcess r) a -> IO a

-- | Combination of <a>submit</a> and <a>cast</a>.
submitCast :: forall o r. (SetMember Lift (Lift IO) r, Typeable o, Member Interrupts r) => SchedulerSession r -> Server o -> Api o  'Asynchronous -> IO ()

-- | Combination of <a>submit</a> and <a>cast</a>.
submitCall :: forall o q r. (SetMember Lift (Lift IO) r, Typeable o, Typeable q, NFData q, Show q, Member Interrupts r) => SchedulerSession r -> Server o -> Api o ( 'Synchronous q) -> IO q


-- | Asynchronous Logging
module Control.Eff.Log.Channel

-- | Fork a new process in which the given log message writer, will listen
--   on a message queue, to which all log message will be relayed.
--   
--   If an exception is received, the logging process will be killed.
--   
--   Log messages are deeply evaluated before being sent to the logger
--   process, to prevent that lazy evaluation leads to heavy work being
--   done in the logger process instead of the caller process.
--   
--   Example:
--   
--   <pre>
--   exampleAsyncLogging :: IO ()
--   exampleAsyncLogging =
--       runLift
--     $ withSomeLogging @IO
--     $ withAsyncLogging (1000::Int) consoleLogWriter
--     $ do logMsg "test 1"
--          logMsg "test 2"
--          logMsg "test 3"
--   </pre>
withAsyncLogging :: (LogsTo IO e, Lifted IO e, MonadBaseControl IO (Eff e), Integral len) => len -> LogWriter IO -> Eff e a -> Eff e a


-- | A logging effect.
--   
--   There is just one log message type: <a>LogMessage</a> and it is
--   written using <a>logMsg</a> and the functions built on top of it.
--   
--   The <a>Logs</a> effect is tightly coupled with the
--   <a>LogWriterReader</a> effect. When using the
--   <a>ControlMonadBaseControl</a> instance, the underlying monad of the
--   <a>LogWriter</a>, that is expected to be present through the
--   respective <a>LogWriterReader</a>, is constrained to be the base monad
--   itself, e.g. <a>IO</a>.
--   
--   The log message type is fixed to <a>LogMessage</a>, and there is a
--   type class for converting to that, call <a>ToLogMessage</a>.
--   
--   There is a single global <a>LogPredicate</a> that can be used to
--   suppress logs directly at the point where they are sent, in the
--   <a>logMsg</a> function.
--   
--   Note that all logging is eventually done via <a>logMsg</a>;
--   <a>logMsg</a> is the <b>only</b> place where log filtering should
--   happen.
--   
--   Also, <a>LogMessage</a>s are evaluated using <a>deepseq</a>,
--   <b>after</b> they pass the <a>LogPredicate</a>, also inside
--   <a>logMsg</a>.
--   
--   Example:
--   
--   <pre>
--   exampleLogging :: IO ()
--   exampleLogging =
--       runLift
--     $ withLogging consoleLogWriter
--     $ do
--         logDebug "test 1.1"
--         logError "test 1.2"
--         censorLogs (prefixLogMessagesWith "NESTED: ")
--          $ do
--               addLogWriter debugTraceLogWriter
--                $ setLogPredicate (\m -&gt; (view lmMessage m) /= "not logged")
--                $ do
--                     logInfo "not logged"
--                     logMsg "test 2.1"
--               logWarning "test 2.2"
--         logCritical "test 1.3"
--   </pre>
--   
--   <h2>Asynchronous Logging</h2>
--   
--   Logging in a <a>withAsync</a> spawned thread is done using
--   <a>withAsyncLogging</a>.
--   
--   <h2><a>LogPredicate</a>s</h2>
--   
--   See <a>Control.Eff.Log.Handler#LogPredicate</a>
module Control.Eff.Log

-- | Example code for:
--   
--   <ul>
--   <li><a>withConsoleLogging</a></li>
--   <li><a>ioLogWriter</a></li>
--   <li><a>printLogMessage</a></li>
--   <li><a>logDebug</a></li>
--   <li><a>logError</a></li>
--   <li><a>prefixLogMessagesWith</a></li>
--   <li><a>addLogWriter</a></li>
--   <li><a>debugTraceLogWriter</a></li>
--   <li><a>setLogPredicate</a></li>
--   <li><a>logInfo</a></li>
--   <li><a>logMsg</a></li>
--   <li><a>logWarning</a></li>
--   <li><a>logCritical</a></li>
--   <li><a>lmMessage</a></li>
--   </ul>
exampleLogging :: IO ()

-- | Example code for:
--   
--   <ul>
--   <li><a>withLogging</a></li>
--   <li><a>consoleLogWriter</a></li>
--   </ul>
exampleWithLogging :: IO ()

-- | Example code for:
--   
--   <ul>
--   <li><a>withSomeLogging</a></li>
--   <li><a>PureLogWriter</a></li>
--   <li><a>logDebug</a></li>
--   </ul>
exampleWithSomeLogging :: ()

-- | Example code for:
--   
--   <ul>
--   <li><a>setLogPredicate</a></li>
--   <li><a>modifyLogPredicate</a></li>
--   <li><a>lmMessageStartsWith</a></li>
--   <li><a>lmSeverityIs</a></li>
--   <li><a>lmSeverityIsAtLeast</a></li>
--   <li><a>includeLogMessages</a></li>
--   <li><a>excludeLogMessages</a></li>
--   </ul>
exampleLogPredicate :: IO Int

-- | Example code for:
--   
--   <ul>
--   <li><a>runCapturedLogsWriter</a></li>
--   <li><a>listLogWriter</a></li>
--   <li><a>mappingLogWriter</a></li>
--   <li><a>filteringLogWriter</a></li>
--   </ul>
exampleLogCapture :: IO ()

-- | Example code for:
--   
--   <ul>
--   <li><a>withAsyncLogging</a></li>
--   </ul>
exampleAsyncLogging :: IO ()


-- | A coroutine based, single threaded scheduler for <a>Process</a>es.
module Control.Eff.Concurrent.Process.SingleThreadedScheduler

-- | Handle the <a>Process</a> effect, as well as all lower effects using
--   an effect handler function.
--   
--   Execute the <b>main</b> <a>Process</a> and all the other processes
--   <a>spawn</a>ed by it in the current thread concurrently, using a
--   co-routine based, round-robin scheduler. If a process exits with eg.g
--   <a>exitNormally</a> or <a>exitWithError</a> or is killed by another
--   process <tt>Left ...</tt> is returned. Otherwise, the result will be
--   wrapped in a <tt>Right</tt>.
--   
--   Every time a process _yields_ the effects are evaluated down to the a
--   value of type <tt>m (Either String a)</tt>.
--   
--   If the evaluator function runs the action down e.g. <tt>IO</tt> this
--   might improve memory consumption, for long running services, with
--   processes that loop endlessly.
scheduleM :: forall m r a. Monad m => (forall b. Eff r b -> m b) -> m () -> Eff (InterruptableProcess r) a -> m (Either (ExitReason  'NoRecovery) a)

-- | Like <a>scheduleIO</a> but <i>pure</i>. The <tt>yield</tt> effect is
--   just <tt>return ()</tt>. <tt>schedulePure == runIdentity .
--   <a>scheduleM</a> (Identity . run) (return ())</tt>
schedulePure :: Eff (InterruptableProcess '[Logs, LogWriterReader PureLogWriter]) a -> Either (ExitReason  'NoRecovery) a

-- | Invoke <a>scheduleM</a> with <tt>lift <a>yield</a></tt> as yield
--   effect. <tt>scheduleIO runEff == <a>scheduleM</a> (runLift . runEff)
--   (liftIO <a>yield</a>)</tt>
scheduleIO :: MonadIO m => (forall b. Eff r b -> Eff '[Lift m] b) -> Eff (InterruptableProcess r) a -> m (Either (ExitReason  'NoRecovery) a)

-- | Invoke <a>scheduleM</a> with <tt>lift <a>yield</a></tt> as yield
--   effect. <tt>scheduleMonadIOEff == <a>scheduleM</a> id (liftIO
--   <a>yield</a>)</tt>
scheduleMonadIOEff :: MonadIO (Eff r) => Eff (InterruptableProcess r) a -> Eff r (Either (ExitReason  'NoRecovery) a)

-- | Run processes that have the <a>Logs</a> and the <a>Lift</a> effects.
--   The user must provide a log handler function.
--   
--   Log messages are evaluated strict.
--   
--   <pre>
--   scheduleIOWithLogging == <a>scheduleIO</a> . <a>withLogging</a>
--   </pre>
scheduleIOWithLogging :: HasCallStack => LogWriter IO -> Eff (InterruptableProcess LoggingAndIo) a -> IO (Either (ExitReason  'NoRecovery) a)

-- | Execute a <a>Process</a> using <a>scheduleM</a> on top of <a>Lift</a>
--   <tt>IO</tt> and <a>withLogging</a> <tt>String</tt> effects.
defaultMainSingleThreaded :: HasCallStack => Eff (InterruptableProcess LoggingAndIo) () -> IO ()
instance GHC.Show.Show (Control.Eff.Concurrent.Process.SingleThreadedScheduler.OnYield r a)
instance GHC.Show.Show (Control.Eff.Concurrent.Process.SingleThreadedScheduler.STS r m)


-- | Implement Erlang style message passing concurrency.
--   
--   This module contains <a>spawn</a> which handles the <a>Process</a>
--   effects, using <a>TQueue</a>s and <a>withAsync</a>.
--   
--   This aims to be a pragmatic implementation, so even logging is
--   supported.
--   
--   At the core is a <i>main process</i> that enters <a>schedule</a> and
--   creates all of the internal state stored in <a>TVar</a>s to manage
--   processes with message queues.
module Control.Eff.Concurrent.Process.ForkIOScheduler

-- | This is the main entry point to running a message passing concurrency
--   application. This function takes a <a>Process</a> on top of the
--   <a>SchedulerIO</a> effect for concurrent logging.
schedule :: HasCallStack => Eff InterruptableProcEff () -> Eff LoggingAndIo ()

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMain :: HasCallStack => Eff InterruptableProcEff () -> IO ()

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMainWithLogWriter :: HasCallStack => LogWriter IO -> Eff InterruptableProcEff () -> IO ()

-- | The concrete list of <a>Eff</a>ects of processes compatible with this
--   scheduler. This builds upon <a>SchedulerIO</a>.
type ProcEff = ConsProcess SchedulerIO

-- | The concrete list of the effects, that the <a>Process</a> uses
type InterruptableProcEff = InterruptableProcess SchedulerIO

-- | The concrete list of <a>Eff</a>ects for this scheduler implementation.
type SchedulerIO = (Reader SchedulerState : LoggingAndIo)

-- | Type class constraint to indicate that an effect union contains the
--   effects required by every process and the scheduler implementation
--   itself.
type HasSchedulerIO r = (HasCallStack, Lifted IO r, SchedulerIO <:: r)
instance GHC.Show.Show Control.Eff.Concurrent.Process.ForkIOScheduler.ProcessInfo
instance Data.Default.Class.Default Control.Eff.Concurrent.Process.ForkIOScheduler.MessageQ


-- | Support code to implement <a>Api</a> _server_ processes.
module Control.Eff.Concurrent.Api.Server

-- | <i>Serve</i> an <a>Api</a> in a newly spawned process.
spawnApiServer :: forall api eff. (ToServerPids api, HasCallStack) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Serve</i> an <a>Api</a> in a newly spawned -and linked - process.
spawnLinkApiServer :: forall api eff. (ToServerPids api, HasCallStack) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; the callbacks
--   have access to some state initialed by the function in the first
--   parameter.
spawnApiServerStateful :: forall api eff state. (HasCallStack, ToServerPids api) => Eff (InterruptableProcess eff) state -> MessageCallback api (State state : InterruptableProcess eff) -> InterruptCallback (State state : ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks.
spawnApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks. Links to the calling process like <a>linkProcess</a> would.
spawnLinkApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | Receive loop for <a>Api</a> <a>call</a>s. This starts a receive loop
--   for a <a>MessageCallback</a>. It is used behind the scenes by
--   <a>spawnLinkApiServerEffectful</a> and <a>spawnApiServerEffectful</a>.
apiServerLoop :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff) => MessageCallback api serverEff -> InterruptCallback serverEff -> Eff serverEff ()

-- | A command to the server loop started by <a>apiServerLoop</a>.
--   Typically returned by a <a>MessageCallback</a> to indicate if the
--   server should continue or stop.
data CallbackResult

-- | Tell the server to keep the server loop running
[AwaitNext] :: CallbackResult

-- | Tell the server to exit, this will cause <a>apiServerLoop</a> to stop
--   handling requests without exiting the process.
[StopServer] :: InterruptReason -> CallbackResult

-- | An existential wrapper around a <a>MessageSelector</a> and a function
--   that handles the selected message. The <tt>api</tt> type parameter is
--   a phantom type.
--   
--   The return value if the handler function is a <a>CallbackResult</a>.
data MessageCallback api eff
[MessageCallback] :: MessageSelector a -> (a -> Eff eff CallbackResult) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCasts :: forall api eff. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous)) => (Api api  'Asynchronous -> Eff eff CallbackResult) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   handleCalls
--     ( (RentBook bookId customerId) runCall -&gt;
--        runCall $ do
--            rentalIdE &lt;- rentBook bookId customerId
--            case rentalIdE of
--              -- on fail we just don't send a reply, let the caller run into
--              -- timeout
--              Left err -&gt; return (Nothing, AwaitNext)
--              Right rentalId -&gt; return (Just rentalId, AwaitNext))
--   </pre>
handleCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall secret reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult) -> secret) -> secret) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCastsAndCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous), SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (Api api  'Asynchronous -> Eff eff CallbackResult) -> (forall secret reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult) -> secret) -> secret) -> MessageCallback api eff

-- | A variation of <a>handleCalls</a> that allows to defer a reply to a
--   call.
handleCallsDeferred :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply))) => RequestOrigin (Api api ( 'Synchronous reply)) -> Api api ( 'Synchronous reply) -> Eff eff CallbackResult) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleMessages :: forall eff a. (HasCallStack, NFData a, Typeable a) => (a -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleSelectedMessages :: forall eff a. HasCallStack => MessageSelector a -> (a -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleAnyMessages :: forall eff. HasCallStack => (Dynamic -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleProcessDowns :: forall eff. HasCallStack => (MonitorReference -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
dropUnhandledMessages :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that terminates if there are unhandled
--   messages.
exitOnUnhandled :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
logUnhandledMessages :: forall eff. (Member Logs eff, HasCallStack) => MessageCallback '[] eff

-- | Compose two <a>Api</a>s to a type-level pair of them.
--   
--   <pre>
--   handleCalls api1calls ^: handleCalls api2calls ^:
--   </pre>
(^:) :: forall (api1 :: Type) (apis2 :: [Type]) eff. HasCallStack => MessageCallback api1 eff -> MessageCallback apis2 eff -> MessageCallback (api1 : apis2) eff
infixr 5 ^:

-- | Make a fallback handler, i.e. a handler to which no other can be
--   composed to from the right.
fallbackHandler :: forall api eff. HasCallStack => MessageCallback api eff -> MessageCallback '[] eff

-- | Helper type class for the return values of <a>spawnApiServer</a> et
--   al.
class ToServerPids (t :: k) where {
    type family ServerPids t;
}
toServerPids :: ToServerPids t => proxy t -> ProcessId -> ServerPids t

-- | Just a wrapper around a function that will be applied to the result of
--   a <a>MessageCallback</a>s <a>StopServer</a> clause, or an
--   <a>InterruptReason</a> caught during the execution of <tt>receive</tt>
--   or a <a>MessageCallback</a>
data InterruptCallback eff
[InterruptCallback] :: (InterruptReason -> Eff eff CallbackResult) -> InterruptCallback eff

-- | A smart constructor for <a>InterruptCallback</a>s
stopServerOnInterrupt :: forall eff. HasCallStack => InterruptCallback eff
instance Data.Default.Class.Default (Control.Eff.Concurrent.Api.Server.InterruptCallback eff)
instance Control.Eff.Concurrent.Api.Server.ToServerPids '[]
instance (Control.Eff.Concurrent.Api.Server.ToServerPids api1, Control.Eff.Concurrent.Api.Server.ToServerPids api2) => Control.Eff.Concurrent.Api.Server.ToServerPids (api1 : api2)
instance Control.Eff.Concurrent.Api.Server.ToServerPids api1 => Control.Eff.Concurrent.Api.Server.ToServerPids api1
instance forall k (api :: k) (eff :: [* -> *]). GHC.Base.Semigroup (Control.Eff.Concurrent.Api.Server.MessageCallback api eff)
instance forall k (api :: k) (eff :: [* -> *]). GHC.Base.Monoid (Control.Eff.Concurrent.Api.Server.MessageCallback api eff)
instance forall k (api :: k) (eff :: [* -> *]). Data.Default.Class.Default (Control.Eff.Concurrent.Api.Server.MessageCallback api eff)


-- | Observer Effects
--   
--   This module supports the implementation of observers and observables.
--   Expected use case is event propagation.
module Control.Eff.Concurrent.Api.Observer

-- | Describes a process that observes another via <a>Asynchronous</a>
--   <a>Api</a> messages.
--   
--   An observer consists of a filter and a process id. The filter converts
--   an observation to a message understood by the observer process, and
--   the <a>ProcessId</a> is used to send the message.
data Observer o
[Observer] :: (Show (Server p), Typeable p, Typeable o) => (o -> Maybe (Api p  'Asynchronous)) -> Server p -> Observer o

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)

-- | And an <a>Observer</a> to the set of reciepients for all observations
--   reported by <a>observed</a>. Note that the observers are keyed by the
--   observing process, i.e. a previous entry for the process contained in
--   the <a>Observer</a> is overwritten. If you want multiple entries for a
--   single process, just combine several filter functions.
registerObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Send the <a>ForgetObserver</a> message
forgetObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Based on the <a>Api</a> instance for <a>Observer</a> this simplified
--   writing a callback handler for observations. In order to register to
--   and <a>ObserverRegistry</a> use <a>toObserver</a>.
handleObservations :: (HasCallStack, Typeable o, SetMember Process (Process q) r) => (o -> Eff r CallbackResult) -> MessageCallback (Observer o) r

-- | Use a <a>Server</a> as an <a>Observer</a> for
--   <a>handleObservations</a>.
toObserver :: Typeable o => Server (Observer o) -> Observer o

-- | Create an <a>Observer</a> that conditionally accepts all observations
--   of the given type and applies the given function to them; the function
--   takes an observation and returns an <a>Api</a> cast that the observer
--   server is compatible to.
toObserverFor :: (Typeable a, Typeable o) => (o -> Api a  'Asynchronous) -> Server a -> Observer o

-- | An <a>Api</a> for managing <a>Observer</a>s, encompassing registration
--   and de-registration of <a>Observer</a>s.
data ObserverRegistry o

-- | Alias for the effect that contains the observers managed by
--   <a>manageObservers</a>
type ObserverState o = State (Observers o)

-- | Provide the implementation for the <a>ObserverRegistry</a> Api, this
--   handled <a>RegisterObserver</a> and <a>ForgetObserver</a> messages. It
--   also adds the <a>ObserverState</a> constraint to the effect list.
handleObserverRegistration :: forall o q r. (HasCallStack, Typeable o, SetMember Process (Process q) r, Member (ObserverState o) r) => MessageCallback (ObserverRegistry o) r

-- | Keep track of registered <a>Observer</a>s.
--   
--   Handle the <a>ObserverState</a> introduced by
--   <a>handleObserverRegistration</a>.
manageObservers :: Eff (ObserverState o : r) a -> Eff r a

-- | Report an observation to all observers. The process needs to
--   <a>manageObservers</a> and to <a>handleObserverRegistration</a>.
observed :: forall o r q. (SetMember Process (Process q) r, Member (ObserverState o) r, Member Interrupts r) => o -> Eff r ()
instance GHC.Show.Show (Control.Eff.Concurrent.Api.Observer.Observer o)
instance GHC.Classes.Ord (Control.Eff.Concurrent.Api.Observer.Observer o)
instance GHC.Classes.Eq (Control.Eff.Concurrent.Api.Observer.Observer o)


-- | A small process to capture and _share_ observation's by enqueueing
--   them into an STM <a>TBQueue</a>.
module Control.Eff.Concurrent.Api.Observer.Queue

-- | Contains a <a>TBQueue</a> capturing observations. See
--   <a>spawnLinkObservationQueueWriter</a>, <a>readObservationQueue</a>.
data ObservationQueue a

-- | A <a>Reader</a> for an <a>ObservationQueue</a>.
type ObservationQueueReader a = Reader (ObservationQueue a)

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. This blocks
--   until something was captured or an interrupt or exceptions was thrown.
--   For a non-blocking variant use <a>tryReadObservationQueue</a> or
--   <a>flushObservationQueue</a>.
readObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r o

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. Return the
--   oldest enqueued observation immediately or <a>Nothing</a> if the queue
--   is empty. Use <a>readObservationQueue</a> to block until an
--   observation is observed.
tryReadObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r (Maybe o)

-- | Read at once all currently queued observations captured and enqueued
--   in the shared <a>TBQueue</a> by
--   <a>spawnLinkObservationQueueWriter</a>. This returns immediately all
--   currently enqueued observations. For a blocking variant use
--   <a>readObservationQueue</a>.
flushObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r [o]

-- | Create a mutable queue for observations. Use
--   <a>spawnLinkObservationQueueWriter</a> for a simple way to get a
--   process that enqueues all observations.
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   withObservationQueue 100 $ do
--     q  &lt;- ask @(ObservationQueueReader TestEvent)
--     wq &lt;- spawnLinkObservationQueueWriter q
--     registerObserver wq testServer
--     ...
--     cast testServer DoSomething
--     evt &lt;- readObservationQueue @TestEvent
--     ...
--   </pre>
withObservationQueue :: forall o b e len. (HasCallStack, Typeable o, Show o, Member Logs e, Lifted IO e, Integral len, Member Interrupts e) => len -> Eff (ObservationQueueReader o : e) b -> Eff e b

-- | Spawn a process that can be used as an <a>Observer</a> that enqueues
--   the observations into an <a>ObservationQueue</a>. See
--   <a>withObservationQueue</a> for an example.
--   
--   The observations can be obtained by <a>readObservationQueue</a>. All
--   observations are captured up to the queue size limit, such that the
--   first message received will be first message returned by
--   <a>readObservationQueue</a>.
spawnLinkObservationQueueWriter :: forall o q. (Typeable o, Show o, Member Logs q, Lifted IO q, HasCallStack) => ObservationQueue o -> Eff (InterruptableProcess q) (Observer o)


-- | In rare occasions GHC optimizes innocent looking loops into
--   space-leaking monsters. See the discussion here: <a>GHC issue
--   13080</a> for more details, or <a>this blog post about space leaks in
--   nested loops</a>
--   
--   These functions in this module <b><i>might</i></b> help, at least in
--   conjunction with the <tt>-fno-full-laziness</tt> GHC option.
--   
--   There is a unit test in the sources of this module, which can be used
--   to do a comperative heap profiling of these function vs. their
--   counterparts in the <tt>base</tt> package.
--   
--   Here are the images of the profiling results, the images show that the
--   functions in this module do not leak space, compared to the original
--   functions (<a>forever</a> and <a>replicateM_</a>):
--   
module Control.Eff.Loop

-- | A version of <a>forever</a> that hopefully tricks GHC into
--   <b><i>not</i></b> creating a space leak. The intuition is, that we
--   want to do something that is <i>cheap</i>, and hence should be
--   <b>recomputed</b> instead of shared.
foreverCheap :: Monad m => m a -> m ()

-- | A version of <a>replicateM_</a> that hopefully tricks GHC into
--   <b><i>not</i></b> creating a space leak. The intuition is, that we
--   want to do something that is <i>cheap</i>, and hence should be
--   <b>recomputed</b> instead of shared.
replicateCheapM_ :: Monad m => Int -> m a -> m ()


-- | Erlang style processes with message passing concurrency based on
--   (more) <tt>extensible-effects</tt>.
module Control.Eff.Concurrent

-- | Each process is identified by a single process id, that stays constant
--   throughout the life cycle of a process. Also, message sending relies
--   on these values to address messages to processes.
newtype ProcessId
ProcessId :: Int -> ProcessId
[_fromProcessId] :: ProcessId -> Int

-- | A monitored process exited. This message is sent to a process by the
--   scheduler, when a process that was monitored died.
data ProcessDown
ProcessDown :: !MonitorReference -> !SomeExitReason -> ProcessDown
[downReference] :: ProcessDown -> !MonitorReference
[downReason] :: ProcessDown -> !SomeExitReason

-- | A value that contains a unique reference of a process monitoring.
data MonitorReference
MonitorReference :: Int -> ProcessId -> MonitorReference
[monitorIndex] :: MonitorReference -> Int
[monitoredProcess] :: MonitorReference -> ProcessId

-- | An existential wrapper around <a>ExitReason</a>
data SomeExitReason
[SomeExitReason] :: ExitReason x -> SomeExitReason

-- | This adds a layer of the <a>Interrupts</a> effect on top of
--   <a>ConsProcess</a>
type InterruptableProcess e = Interrupts : ConsProcess e

-- | <a>Exc</a>eptions containing <a>InterruptReason</a>s. See
--   <a>handleInterrupts</a>, <a>exitOnInterrupt</a> or
--   <a>provideInterrupts</a>
type Interrupts = Exc InterruptReason

-- | <a>ExitReason</a>s which are recoverable are interrupts.
type InterruptReason = ExitReason  'Recoverable

-- | A sum-type with reasons for why a process exists the scheduling loop,
--   this includes errors, that can occur when scheduling messages.
data ExitReason (t :: ExitRecovery)

-- | A process has finished a unit of work and might exit or work on
--   something else. This is primarily used for interrupting infinite
--   server loops, allowing for additional cleanup work before exiting
--   (e.g. with <a>ExitNormally</a>)
[ProcessFinished] :: ExitReason  'Recoverable

-- | A process that should be running was not running.
[ProcessNotRunning] :: ProcessId -> ExitReason  'Recoverable

-- | A linked process is down
[LinkedProcessCrashed] :: ProcessId -> ExitReason  'Recoverable

-- | An exit reason that has an error message but isn't <a>Recoverable</a>.
[ProcessError] :: String -> ExitReason  'Recoverable

-- | A process function returned or exited without any error.
[ExitNormally] :: ExitReason  'NoRecovery

-- | An unhandled <a>Recoverable</a> allows <a>NoRecovery</a>.
[NotRecovered] :: ExitReason  'Recoverable -> ExitReason  'NoRecovery

-- | An unexpected runtime exception was thrown, i.e. an exception derived
--   from <a>SomeException</a>
[UnexpectedException] :: String -> String -> ExitReason  'NoRecovery

-- | A process was cancelled (e.g. killed, in <a>cancel</a>)
[Killed] :: ExitReason  'NoRecovery

-- | This value indicates whether a process exited in way consistent with
--   the planned behaviour or not.
data ExitSeverity
NormalExit :: ExitSeverity
Crash :: ExitSeverity

-- | This kind is used to indicate if a <a>ExitReason</a> can be treated
--   like a short interrupt which can be handled or ignored.
data ExitRecovery
Recoverable :: ExitRecovery
NoRecovery :: ExitRecovery

-- | The state that a <a>Process</a> is currently in.
data ProcessState

-- | The process has just been started but not scheduled yet.
ProcessBooting :: ProcessState

-- | The process yielded it's time slice
ProcessIdle :: ProcessState

-- | The process is busy with non-blocking
ProcessBusy :: ProcessState

-- | The process is busy with sending a message
ProcessBusySending :: ProcessState

-- | The process is busy with killing
ProcessBusySendingShutdown :: ProcessState

-- | The process is busy with killing
ProcessBusySendingInterrupt :: ProcessState

-- | The process blocked by a <a>receiveAnyMessage</a>
ProcessBusyReceiving :: ProcessState

-- | The process blocked by a <a>linkProcess</a>
ProcessBusyLinking :: ProcessState

-- | The process blocked by a <a>unlinkProcess</a>
ProcessBusyUnlinking :: ProcessState

-- | The process blocked by a <a>monitor</a>
ProcessBusyMonitoring :: ProcessState

-- | The process blocked by a <a>demonitor</a>
ProcessBusyDemonitoring :: ProcessState

-- | The process was interrupted
ProcessInterrupted :: ProcessState

-- | The process was shutdown or crashed
ProcessShuttingDown :: ProcessState

-- | <i>Cons</i> <a>Process</a> onto a list of effects.
type ConsProcess r = Process r : r

-- | Every function for <a>Process</a> things needs such a proxy value for
--   the low-level effect list, i.e. the effects identified by
--   <tt><b>r</b></tt> in <tt><a>Process</a> r : r</tt>, this might be
--   dependent on the scheduler implementation.
data SchedulerProxy :: [Type -> Type] -> Type

-- | Tell the type checker what effects we have below <a>Process</a>
[SchedulerProxy] :: SchedulerProxy q

-- | Like <a>SchedulerProxy</a> but shorter
[SP] :: SchedulerProxy q

-- | Like <a>SP</a> but different
[Scheduler] :: SchedulerProxy q

-- | A function that decided if the next message will be received by
--   <a>ReceiveSelectedMessage</a>. It conveniently is an instance of
--   <a>Alternative</a> so the message selector can be combined: &gt; &gt;
--   selectInt :: MessageSelector Int &gt; selectInt = selectMessage &gt;
--   &gt; selectString :: MessageSelector String &gt; selectString =
--   selectMessage &gt; &gt; selectIntOrString :: MessageSelector (Either
--   Int String) &gt; selectIntOrString = &gt; Left <a>$</a>
--   selectTimeout<a>|</a> Right <a>$</a> selectString
data MessageSelector a

-- | Every <a>Process</a> action returns it's actual result wrapped in this
--   type. It will allow to signal errors as well as pass on normal results
--   such as incoming messages.
data ResumeProcess v

-- | The current operation of the process was interrupted with a
--   <a>ExitReason</a>. If <a>isRecoverable</a> holds for the given reason,
--   the process may choose to continue.
[Interrupted] :: InterruptReason -> ResumeProcess v

-- | The process may resume to do work, using the given result.
[ResumeWith] :: a -> ResumeProcess a

-- | The process effect is the basis for message passing concurrency. This
--   effect describes an interface for concurrent, communicating isolated
--   processes identified uniquely by a process-id.
--   
--   Processes can raise exceptions that can be caught, exit gracefully or
--   with an error, or be killed by other processes, with the option of
--   ignoring the shutdown request.
--   
--   Process Scheduling is implemented in different modules. All scheduler
--   implementations should follow some basic rules:
--   
--   <ul>
--   <li>fair scheduling</li>
--   <li>sending a message does not block</li>
--   <li>receiving a message does block</li>
--   <li>spawning a child blocks only a very moment</li>
--   <li>a newly spawned process shall be scheduled before the parent
--   process after</li>
--   <li>the spawnRaw</li>
--   <li>when the first process exists, all process should be killed
--   immediately</li>
--   </ul>
data Process (r :: [Type -> Type]) b

-- | Remove all messages from the process' message queue
[FlushMessages] :: Process r (ResumeProcess [Dynamic])

-- | In cooperative schedulers, this will give processing time to the
--   scheduler. Every other operation implicitly serves the same purpose.
[YieldProcess] :: Process r (ResumeProcess ())

-- | Return the current <a>ProcessId</a>
[SelfPid] :: Process r (ResumeProcess ProcessId)

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>.
[Spawn] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Start a new process, and <a>Link</a> to it .
[SpawnLink] :: Eff (Process r : r) () -> Process r (ResumeProcess ProcessId)

-- | Get the process state (or <a>Nothing</a> if the process is dead)
[GetProcessState] :: ProcessId -> Process r (ResumeProcess (Maybe ProcessState))

-- | Shutdown the process; irregardless of the exit reason, this function
--   never returns,
[Shutdown] :: ExitReason  'NoRecovery -> Process r a

-- | Raise an error, that can be handled.
[SendShutdown] :: ProcessId -> ExitReason  'NoRecovery -> Process r (ResumeProcess ())

-- | Request that another a process interrupts. The targeted process is
--   interrupted and gets an <a>Interrupted</a>, the target process may
--   decide to ignore the interrupt and continue as if nothing happened.
[SendInterrupt] :: ProcessId -> InterruptReason -> Process r (ResumeProcess ())

-- | Send a message to a process addressed by the <a>ProcessId</a>. Sending
--   a message should <b>always succeed</b> and return <b>immediately</b>,
--   even if the destination process does not exist, or does not accept
--   messages of the given type.
[SendMessage] :: ProcessId -> Dynamic -> Process r (ResumeProcess ())

-- | Receive a message that matches a criteria. This should block until an
--   a message was received. The message is returned as a
--   <a>ResumeProcess</a> value. The function should also return if an
--   exception was caught or a shutdown was requested.
[ReceiveSelectedMessage] :: forall r a. MessageSelector a -> Process r (ResumeProcess a)

-- | Generate a unique <a>Int</a> for the current process.
[MakeReference] :: Process r (ResumeProcess Int)

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
[Monitor] :: ProcessId -> Process r (ResumeProcess MonitorReference)

-- | Remove a monitor.
[Demonitor] :: MonitorReference -> Process r (ResumeProcess ())

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>ExitReason</a>
--   <a>LinkedProcessCrashed</a>.
[Link] :: ProcessId -> Process r (ResumeProcess ())

-- | Unlink the calling process from the other process.
[Unlink] :: ProcessId -> Process r (ResumeProcess ())

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a>. It will also <a>force</a> the result.
selectMessage :: (NFData t, Typeable t) => MessageSelector t

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a>. It will also <a>force</a> the result.
selectMessageLazy :: Typeable t => MessageSelector t

-- | Create a message selector from a predicate. It will <a>force</a> the
--   result.
filterMessage :: (Typeable a, NFData a) => (a -> Bool) -> MessageSelector a

-- | Create a message selector from a predicate. It will <a>force</a> the
--   result.
filterMessageLazy :: Typeable a => (a -> Bool) -> MessageSelector a

-- | Select a message of type <tt>a</tt> and apply the given function to
--   it. If the function returns <a>Just</a> The
--   <a>ReceiveSelectedMessage</a> function will return the result (sans
--   <tt>Maybe</tt>). It will <a>force</a> the result.
selectMessageWith :: (Typeable a, NFData b) => (a -> Maybe b) -> MessageSelector b

-- | Select a message of type <tt>a</tt> and apply the given function to
--   it. If the function returns <a>Just</a> The
--   <a>ReceiveSelectedMessage</a> function will return the result (sans
--   <tt>Maybe</tt>). It will <a>force</a> the result.
selectMessageWithLazy :: Typeable a => (a -> Maybe b) -> MessageSelector b

-- | Create a message selector. It will <a>force</a> the result.
selectDynamicMessage :: NFData a => (Dynamic -> Maybe a) -> MessageSelector a

-- | Create a message selector.
selectDynamicMessageLazy :: (Dynamic -> Maybe a) -> MessageSelector a

-- | Create a message selector that will match every message. This is
--   <i>lazy</i> because the result is not <a>force</a>ed.
selectAnyMessageLazy :: MessageSelector Dynamic

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a> with a proxy argument. It will also <a>force</a>
--   the result.
selectMessageProxy :: forall proxy t. (NFData t, Typeable t) => proxy t -> MessageSelector t

-- | Create a message selector for a value that can be obtained by
--   <a>fromDynamic</a> with a proxy argument. It will also <a>force</a>
--   the result.
selectMessageProxyLazy :: forall proxy t. Typeable t => proxy t -> MessageSelector t

-- | Return a <a>SchedulerProxy</a> for a <a>Process</a> effect.
thisSchedulerProxy :: Eff (Process r : r) (SchedulerProxy r)

-- | Get the <a>ExitRecovery</a>
toExitRecovery :: ExitReason r -> ExitRecovery

-- | Get the <a>ExitSeverity</a> of a <a>ExitReason</a>.
toExitSeverity :: ExitReason e -> ExitSeverity

-- | A predicate for linked process <b>crashes</b>.
isBecauseDown :: Maybe ProcessId -> ExitReason r -> Bool

-- | Handle all <a>InterruptReason</a>s of an <a>InterruptableProcess</a>
--   by wrapping them up in <a>NotRecovered</a> and then do a process
--   <a>Shutdown</a>.
provideInterruptsShutdown :: forall e a. Eff (InterruptableProcess e) a -> Eff (ConsProcess e) a

-- | Handle <a>InterruptReason</a>s arising during process operations, e.g.
--   when a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
handleInterrupts :: (HasCallStack, Member Interrupts r) => (InterruptReason -> Eff r a) -> Eff r a -> Eff r a

-- | Like <a>handleInterrupts</a>, but instead of passing the
--   <a>InterruptReason</a> to a handler function, <a>Either</a> is
--   returned.
tryUninterrupted :: (HasCallStack, Member Interrupts r) => Eff r a -> Eff r (Either InterruptReason a)

-- | Handle interrupts by logging them with <a>logProcessExit</a> and
--   otherwise ignoring them.
logInterrupts :: forall r. (Member Logs r, HasCallStack, Member Interrupts r) => Eff r () -> Eff r ()

-- | Handle <a>InterruptReason</a>s arising during process operations, e.g.
--   when a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
exitOnInterrupt :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r) => Eff r a -> Eff r a

-- | Handle <a>InterruptReason</a>s arising during process operations, e.g.
--   when a linked process crashes while we wait in a
--   <a>receiveSelectedMessage</a> via a call to <a>interrupt</a>.
provideInterrupts :: HasCallStack => Eff (Interrupts : r) a -> Eff r (Either InterruptReason a)

-- | Wrap all (left) <a>InterruptReason</a>s into <a>NotRecovered</a> and
--   return the (right) <a>NoRecovery</a> <a>ExitReason</a>s as is.
mergeEitherInterruptAndExitReason :: Either InterruptReason (ExitReason  'NoRecovery) -> ExitReason  'NoRecovery

-- | Throw an <a>InterruptReason</a>, can be handled by
--   <a>handleInterrupts</a> or <a>exitOnInterrupt</a> or
--   <a>provideInterrupts</a>.
interrupt :: (HasCallStack, Member Interrupts r) => InterruptReason -> Eff r a

-- | A predicate for crashes. A <i>crash</i> happens when a process exits
--   with an <a>ExitReason</a> other than <a>ExitNormally</a>
isCrash :: ExitReason x -> Bool

-- | A predicate for recoverable exit reasons. This predicate defines the
--   exit reasons which functions such as <a>executeAndResume</a>
isRecoverable :: ExitReason x -> Bool

-- | Partition a <a>SomeExitReason</a> back into either a <a>NoRecovery</a>
--   or a <a>Recoverable</a> <a>ExitReason</a>
fromSomeExitReason :: SomeExitReason -> Either (ExitReason  'NoRecovery) InterruptReason

-- | Print a <a>ExitReason</a> to <a>Just</a> a formatted <a>String</a>
--   when <a>isCrash</a> is <a>True</a>. This can be useful in combination
--   with view patterns, e.g.:
--   
--   <pre>
--   logCrash :: ExitReason -&gt; Eff e ()
--   logCrash (toCrashReason -&gt; Just reason) = logError reason
--   logCrash _ = return ()
--   </pre>
--   
--   Though this can be improved to:
--   
--   <pre>
--   logCrash = traverse_ logError . toCrashReason
--   </pre>
toCrashReason :: ExitReason x -> Maybe String

-- | Log the <a>ExitReason</a>s
logProcessExit :: forall e x. (Member Logs e, HasCallStack) => ExitReason x -> Eff e ()

-- | Execute a and action and return the result; if the process is
--   interrupted by an error or exception, or an explicit shutdown from
--   another process, or through a crash of a linked process, i.e. whenever
--   the exit reason satisfies <a>isRecoverable</a>, return the exit
--   reason.
executeAndResume :: forall q r v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r (Either (ExitReason  'Recoverable) v)

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrExit :: forall r q v. (SetMember Process (Process q) r, HasCallStack) => Process q (ResumeProcess v) -> Eff r v

-- | Execute a <a>Process</a> action and resume the process, exit the
--   process when an <a>Interrupts</a> was raised. Use
--   <a>executeAndResume</a> to catch interrupts.
executeAndResumeOrThrow :: forall q r v. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Process q (ResumeProcess v) -> Eff r v

-- | Use <a>executeAndResumeOrExit</a> to execute <a>YieldProcess</a>.
--   Refer to <a>YieldProcess</a> for more information.
yieldProcess :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => Eff r ()

-- | Send a message to a process addressed by the <a>ProcessId</a>. See
--   <a>SendMessage</a>.
sendMessage :: forall r q o. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o) => ProcessId -> o -> Eff r ()

-- | Send a <a>Dynamic</a> value to a process addressed by the
--   <a>ProcessId</a>. See <a>SendMessage</a>.
sendAnyMessage :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> Dynamic -> Eff r ()

-- | Exit a process addressed by the <a>ProcessId</a>. The process will
--   exit, it might do some cleanup, but is ultimately unrecoverable. See
--   <a>SendShutdown</a>.
sendShutdown :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> ExitReason  'NoRecovery -> Eff r ()

-- | Interrupts a process addressed by the <a>ProcessId</a>. The process
--   might exit, or it may continue. | Like <a>sendInterrupt</a>, but also
--   return <tt>True</tt> iff the process to exit exists.
sendInterrupt :: forall r q. (SetMember Process (Process q) r, HasCallStack, Member Interrupts r) => ProcessId -> InterruptReason -> Eff r ()

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. If the new
--   process is interrupted, the process will <a>Shutdown</a> with the
--   <a>InterruptReason</a> wrapped in <a>NotRecovered</a>. For specific
--   use cases it might be better to use <a>spawnRaw</a>.
spawn :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Like <a>spawn</a> but return <tt>()</tt>.
spawn_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ()

-- | Start a new process, and immediately link to it.
spawnLink :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (InterruptableProcess q) () -> Eff r ProcessId

-- | Start a new process, the new process will execute an effect, the
--   function will return immediately with a <a>ProcessId</a>. The spawned
--   process has only the <i>raw</i> <a>ConsProcess</a> effects. For
--   non-library code <a>spawn</a> might be better suited.
spawnRaw :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ProcessId

-- | Like <a>spawnRaw</a> but return <tt>()</tt>.
spawnRaw_ :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff (ConsProcess q) () -> Eff r ()

-- | Return <a>True</a> if the process is alive.
isProcessAlive :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r Bool

-- | Block until a message was received. See <a>ReceiveSelectedMessage</a>
--   for more documentation.
receiveAnyMessage :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r Dynamic

-- | Block until a message was received, that is not <a>Nothing</a> after
--   applying a callback to it. See <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedMessage :: forall r q a. (HasCallStack, Show a, SetMember Process (Process q) r, Member Interrupts r) => MessageSelector a -> Eff r a

-- | Receive and cast the message to some <a>Typeable</a> instance. See
--   <a>ReceiveSelectedMessage</a> for more documentation. This will wait
--   for a message of the return type using <a>receiveSelectedMessage</a>
receiveMessage :: forall a r q. (HasCallStack, Typeable a, Show a, SetMember Process (Process q) r, Member Interrupts r) => Eff r a

-- | Remove and return all messages currently enqueued in the process
--   message queue.
flushMessages :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r [Dynamic]

-- | Enter a loop to receive messages and pass them to a callback, until
--   the function returns <a>Just</a> a result. Only the messages of the
--   given type will be received. If the process is interrupted by an
--   exception of by a <a>SendShutdown</a> from another process, with an
--   exit reason that satisfies <a>isRecoverable</a>, then the callback
--   will be invoked with <tt><a>Left</a> <a>ExitReason</a></tt>, otherwise
--   the process will be exited with the same reason using
--   <a>exitBecause</a>. See also <a>ReceiveSelectedMessage</a> for more
--   documentation.
receiveSelectedLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => MessageSelector a -> (Either InterruptReason a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Like <a>receiveSelectedLoop</a> but <i>not selective</i>. See also
--   <a>selectAnyMessageLazy</a>, <a>receiveSelectedLoop</a>.
receiveAnyLoop :: forall r q endOfLoopResult. (SetMember Process (Process q) r, HasCallStack) => (Either InterruptReason Dynamic -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Like <a>receiveSelectedLoop</a> but refined to casting to a specific
--   <a>Typeable</a> using <a>selectMessageLazy</a>.
receiveLoop :: forall r q a endOfLoopResult. (SetMember Process (Process q) r, HasCallStack, Typeable a) => (Either InterruptReason a -> Eff r (Maybe endOfLoopResult)) -> Eff r endOfLoopResult

-- | Returns the <a>ProcessId</a> of the current process.
self :: (HasCallStack, SetMember Process (Process q) r) => Eff r ProcessId

-- | Generate a unique <a>Int</a> for the current process.
makeReference :: (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Eff r Int

-- | Monitor another process. When the monitored process exits a
--   <a>ProcessDown</a> is sent to the calling process. The return value is
--   a unique identifier for that monitor. There can be multiple monitors
--   on the same process, and a message for each will be sent. If the
--   process is already dead, the <a>ProcessDown</a> message will be sent
--   immediately, without exit reason
monitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r MonitorReference

-- | Remove a monitor created with <a>monitor</a>.
demonitor :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => MonitorReference -> Eff r ()

-- | <a>monitor</a> another process before while performing an action and
--   <a>demonitor</a> afterwards.
withMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> (MonitorReference -> Eff r a) -> Eff r a

-- | A <a>MessageSelector</a> for receiving either a monitor of the given
--   process or another message.
receiveWithMonitor :: (HasCallStack, Member Interrupts r, SetMember Process (Process q) r, Member Interrupts r, Typeable a, Show a) => ProcessId -> MessageSelector a -> Eff r (Either ProcessDown a)

-- | Make an <a>InterruptReason</a> for a <a>ProcessDown</a> message.
--   
--   For example: <tt>doSomething &gt;&gt;= either (interrupt .
--   becauseProcessIsDown) return</tt>
becauseProcessIsDown :: ProcessDown -> InterruptReason

-- | A <a>MessageSelector</a> for the <a>ProcessDown</a> message of a
--   specific process.
selectProcessDown :: MonitorReference -> MessageSelector ProcessDown

-- | Connect the calling process to another process, such that if one of
--   the processes crashes (i.e. <a>isCrash</a> returns <a>True</a>), the
--   other is shutdown with the <a>ExitReason</a>
--   <a>LinkedProcessCrashed</a>.
linkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Unlink the calling process from the other process.
unlinkProcess :: forall r q. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => ProcessId -> Eff r ()

-- | Exit the process with a <a>ExitReason</a>.
exitBecause :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => ExitReason  'NoRecovery -> Eff r a

-- | Exit the process.
exitNormally :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => Eff r a

-- | Exit the process with an error.
exitWithError :: forall r q a. (HasCallStack, SetMember Process (Process q) r) => String -> Eff r a
fromProcessId :: Iso' ProcessId Int

-- | A value to be sent when timer started with <a>startTimer</a> has
--   elapsed.
data TimerElapsed

-- | The reference to a timer started by <a>startTimer</a>, required to
--   stop a timer via <a>cancelTimer</a>.
data TimerReference

-- | A number of micro seconds.
data Timeout

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Nothing</a>. This is based on
--   <a>receiveSelectedAfter</a>.
receiveAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable a, NFData a, Show a) => Timeout -> Eff r (Maybe a)

-- | Wait for a message of the given type for the given time. When no
--   message arrives in time, return <a>Left</a> <a>TimerElapsed</a>. This
--   is based on <a>selectTimerElapsed</a> and <a>startTimer</a>.
receiveSelectedAfter :: forall a r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Show a) => MessageSelector a -> Timeout -> Eff r (Either TimerElapsed a)

-- | A <a>MessageSelector</a> matching <a>TimerElapsed</a> messages created
--   by <a>startTimer</a>.
selectTimerElapsed :: TimerReference -> MessageSelector TimerElapsed

-- | Send a message to a given process after waiting. The message is
--   created by applying the function parameter to the
--   <a>TimerReference</a>, such that the message can directly refer to the
--   timer.
sendAfter :: forall r q message. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable message, NFData message) => ProcessId -> Timeout -> (TimerReference -> message) -> Eff r TimerReference

-- | Start a new timer, after the time has elapsed, <a>TimerElapsed</a> is
--   sent to calling process. The message also contains the
--   <a>TimerReference</a> returned by this function. Use
--   <a>cancelTimer</a> to cancel the timer. Use <a>selectTimerElapsed</a>
--   to receive the message using <a>receiveSelectedMessage</a>. To receive
--   messages with guarded with a timeout see <a>receiveAfter</a>.
startTimer :: forall r q. (Lifted IO q, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => Timeout -> Eff r TimerReference

-- | This is a tag-type that wraps around a <a>ProcessId</a> and holds an
--   <a>Api</a> index type.
newtype Server api
Server :: ProcessId -> Server api
[_fromServer] :: Server api -> ProcessId

-- | The (promoted) constructors of this type specify (at the type level)
--   the reply behavior of a specific constructor of an <tt>Api</tt>
--   instance.
data Synchronicity

-- | Specify that handling a request is a blocking operation with a
--   specific return type, e.g. <tt>('Synchronous (Either RentalError
--   RentalId))</tt>
Synchronous :: Type -> Synchronicity

-- | Non-blocking, asynchronous, request handling
Asynchronous :: Synchronicity

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)
fromServer :: forall api_aSTl api_aT2L. Iso (Server api_aSTl) (Server api_aT2L) ProcessId ProcessId

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
proxyAsServer :: proxy api -> ProcessId -> Server api

-- | Tag a <a>ProcessId</a> with an <a>Api</a> type index to mark it a
--   <a>Server</a> process handling that API
asServer :: forall api. ProcessId -> Server api

-- | The reader effect for <a>ProcessId</a>s for <a>Api</a>s, see
--   <a>registerServer</a>
type ServerReader o = Reader (Server o)

-- | Instead of passing around a <a>Server</a> value and passing to
--   functions like <a>cast</a> or <a>call</a>, a <a>Server</a> can
--   provided by a <a>Reader</a> effect, if there is only a <b>single
--   server</b> for a given <a>Api</a> instance. This type alias is
--   convenience to express that an effect has <a>Process</a> and a reader
--   for a <a>Server</a>.
type ServesApi o r q = (Typeable o, SetMember Process (Process q) r, Member (ServerReader o) r)

-- | Send an <a>Api</a> request that has no return value and return as fast
--   as possible. The type signature enforces that the corresponding
--   <a>Api</a> clause is <a>Asynchronous</a>. The operation never fails,
--   if it is important to know if the message was delivered, use
--   <a>call</a> instead.
cast :: forall r q o. (HasCallStack, SetMember Process (Process q) r, Member Interrupts r, Typeable o, Typeable (Api o  'Asynchronous)) => Server o -> Api o  'Asynchronous -> Eff r ()

-- | Send an <a>Api</a> request and wait for the server to return a result
--   value.
--   
--   The type signature enforces that the corresponding <a>Api</a> clause
--   is <a>Synchronous</a>.
call :: forall result api r q. (SetMember Process (Process q) r, Member Interrupts r, Typeable api, Typeable (Api api ( 'Synchronous result)), Typeable result, HasCallStack, NFData result, Show result) => Server api -> Api api ( 'Synchronous result) -> Eff r result

-- | Run a reader effect that contains <b>the one</b> server handling a
--   specific <a>Api</a> instance.
registerServer :: HasCallStack => Server o -> Eff (ServerReader o : r) a -> Eff r a

-- | Get the <a>Server</a> registered with <a>registerServer</a>.
whereIsServer :: Member (ServerReader o) e => Eff e (Server o)

-- | Like <a>call</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
callRegistered :: (Typeable reply, ServesApi o r q, HasCallStack, NFData reply, Show reply, Member Interrupts r) => Api o ( 'Synchronous reply) -> Eff r reply

-- | Like <a>cast</a> but take the <a>Server</a> from the reader provided
--   by <a>registerServer</a>.
castRegistered :: (Typeable o, ServesApi o r q, HasCallStack, Member Interrupts r) => Api o  'Asynchronous -> Eff r ()

-- | Just a wrapper around a function that will be applied to the result of
--   a <a>MessageCallback</a>s <a>StopServer</a> clause, or an
--   <a>InterruptReason</a> caught during the execution of <tt>receive</tt>
--   or a <a>MessageCallback</a>
data InterruptCallback eff
[InterruptCallback] :: (InterruptReason -> Eff eff CallbackResult) -> InterruptCallback eff

-- | Helper type class for the return values of <a>spawnApiServer</a> et
--   al.
class ToServerPids (t :: k) where {
    type family ServerPids t;
}
toServerPids :: ToServerPids t => proxy t -> ProcessId -> ServerPids t

-- | An existential wrapper around a <a>MessageSelector</a> and a function
--   that handles the selected message. The <tt>api</tt> type parameter is
--   a phantom type.
--   
--   The return value if the handler function is a <a>CallbackResult</a>.
data MessageCallback api eff
[MessageCallback] :: MessageSelector a -> (a -> Eff eff CallbackResult) -> MessageCallback api eff

-- | A command to the server loop started by <a>apiServerLoop</a>.
--   Typically returned by a <a>MessageCallback</a> to indicate if the
--   server should continue or stop.
data CallbackResult

-- | Tell the server to keep the server loop running
[AwaitNext] :: CallbackResult

-- | Tell the server to exit, this will cause <a>apiServerLoop</a> to stop
--   handling requests without exiting the process.
[StopServer] :: InterruptReason -> CallbackResult

-- | <i>Serve</i> an <a>Api</a> in a newly spawned process.
spawnApiServer :: forall api eff. (ToServerPids api, HasCallStack) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Serve</i> an <a>Api</a> in a newly spawned -and linked - process.
spawnLinkApiServer :: forall api eff. (ToServerPids api, HasCallStack) => MessageCallback api (InterruptableProcess eff) -> InterruptCallback (ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; the callbacks
--   have access to some state initialed by the function in the first
--   parameter.
spawnApiServerStateful :: forall api eff state. (HasCallStack, ToServerPids api) => Eff (InterruptableProcess eff) state -> MessageCallback api (State state : InterruptableProcess eff) -> InterruptCallback (State state : ConsProcess eff) -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks.
spawnApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | <i>Server</i> an <a>Api</a> in a newly spawned process; The caller
--   provides an effect handler for arbitrary effects used by the server
--   callbacks. Links to the calling process like <a>linkProcess</a> would.
spawnLinkApiServerEffectful :: forall api eff serverEff. (HasCallStack, ToServerPids api, Member Interrupts serverEff, SetMember Process (Process eff) serverEff) => (forall b. Eff serverEff b -> Eff (InterruptableProcess eff) b) -> MessageCallback api serverEff -> InterruptCallback serverEff -> Eff (InterruptableProcess eff) (ServerPids api)

-- | A smart constructor for <a>MessageCallback</a>s
handleMessages :: forall eff a. (HasCallStack, NFData a, Typeable a) => (a -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleSelectedMessages :: forall eff a. HasCallStack => MessageSelector a -> (a -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleAnyMessages :: forall eff. HasCallStack => (Dynamic -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCasts :: forall api eff. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous)) => (Api api  'Asynchronous -> Eff eff CallbackResult) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   handleCalls
--     ( (RentBook bookId customerId) runCall -&gt;
--        runCall $ do
--            rentalIdE &lt;- rentBook bookId customerId
--            case rentalIdE of
--              -- on fail we just don't send a reply, let the caller run into
--              -- timeout
--              Left err -&gt; return (Nothing, AwaitNext)
--              Right rentalId -&gt; return (Just rentalId, AwaitNext))
--   </pre>
handleCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall secret reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult) -> secret) -> secret) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleCastsAndCalls :: forall api eff effScheduler. (HasCallStack, Typeable api, Typeable (Api api  'Asynchronous), SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (Api api  'Asynchronous -> Eff eff CallbackResult) -> (forall secret reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Api api ( 'Synchronous reply) -> (Eff eff (Maybe reply, CallbackResult) -> secret) -> secret) -> MessageCallback api eff

-- | A variation of <a>handleCalls</a> that allows to defer a reply to a
--   call.
handleCallsDeferred :: forall api eff effScheduler. (HasCallStack, Typeable api, SetMember Process (Process effScheduler) eff, Member Interrupts eff) => (forall reply. (Typeable reply, Typeable (Api api ( 'Synchronous reply))) => RequestOrigin (Api api ( 'Synchronous reply)) -> Api api ( 'Synchronous reply) -> Eff eff CallbackResult) -> MessageCallback api eff

-- | A smart constructor for <a>MessageCallback</a>s
handleProcessDowns :: forall eff. HasCallStack => (MonitorReference -> Eff eff CallbackResult) -> MessageCallback '[] eff

-- | Compose two <a>Api</a>s to a type-level pair of them.
--   
--   <pre>
--   handleCalls api1calls ^: handleCalls api2calls ^:
--   </pre>
(^:) :: forall (api1 :: Type) (apis2 :: [Type]) eff. HasCallStack => MessageCallback api1 eff -> MessageCallback apis2 eff -> MessageCallback (api1 : apis2) eff
infixr 5 ^:

-- | Make a fallback handler, i.e. a handler to which no other can be
--   composed to from the right.
fallbackHandler :: forall api eff. HasCallStack => MessageCallback api eff -> MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
dropUnhandledMessages :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that terminates if there are unhandled
--   messages.
exitOnUnhandled :: forall eff. HasCallStack => MessageCallback '[] eff

-- | A <a>fallbackHandler</a> that drops the left-over messages.
logUnhandledMessages :: forall eff. (Member Logs eff, HasCallStack) => MessageCallback '[] eff

-- | A smart constructor for <a>InterruptCallback</a>s
stopServerOnInterrupt :: forall eff. HasCallStack => InterruptCallback eff

-- | Wraps the source <a>ProcessId</a> and a unique identifier for a
--   <a>Call</a>.
data RequestOrigin request
RequestOrigin :: !ProcessId -> !Int -> RequestOrigin request
[_requestOriginPid] :: RequestOrigin request -> !ProcessId
[_requestOriginCallRef] :: RequestOrigin request -> !Int

-- | The wrapper around replies to <a>Call</a>s.
data Reply request
[Reply] :: (Typeable api, Typeable reply) => Proxy (Api api ( 'Synchronous reply)) -> Int -> reply -> Reply (Api api ( 'Synchronous reply))

-- | A wrapper sum type for calls and casts for the methods of an
--   <a>Api</a> subtype
data Request api
[Call] :: forall api reply. (Typeable api, Typeable reply, Typeable (Api api ( 'Synchronous reply))) => Int -> ProcessId -> Api api ( 'Synchronous reply) -> Request api
[Cast] :: forall api. (Typeable api, Typeable (Api api  'Asynchronous)) => Api api  'Asynchronous -> Request api

-- | TODO remove
mkRequestOrigin :: request -> ProcessId -> Int -> RequestOrigin request

-- | Send a <a>Reply</a> to a <a>Call</a>.
sendReply :: forall request reply api eff q. (SetMember Process (Process q) eff, Member Interrupts eff, Typeable api, ApiType request ~ api, ReplyType request ~ reply, request ~ Api api ( 'Synchronous reply), Typeable reply) => RequestOrigin request -> reply -> Eff eff ()

-- | This data family defines an API, a communication interface description
--   between at least two processes. The processes act as <b>servers</b> or
--   <b>client(s)</b> regarding a specific instance of this type.
--   
--   The first parameter is usually a user defined phantom type that
--   identifies the <a>Api</a> instance.
--   
--   The second parameter specifies if a specific constructor of an
--   (GADT-like) <tt>Api</tt> instance is <a>Synchronous</a>, i.e. returns
--   a result and blocks the caller or if it is <a>Asynchronous</a>
--   
--   Example:
--   
--   <pre>
--   data BookShop deriving Typeable
--   
--   data instance Api BookShop r where
--     RentBook  :: BookId   -&gt; Api BookShop ('Synchronous (Either RentalError RentalId))
--     BringBack :: RentalId -&gt; Api BookShop 'Asynchronous
--   
--   type BookId = Int
--   type RentalId = Int
--   type RentalError = String
--   </pre>
data family Api (api :: Type) (reply :: Synchronicity)

-- | Alias for the effect that contains the observers managed by
--   <a>manageObservers</a>
type ObserverState o = State (Observers o)

-- | An <a>Api</a> for managing <a>Observer</a>s, encompassing registration
--   and de-registration of <a>Observer</a>s.
data ObserverRegistry o

-- | Describes a process that observes another via <a>Asynchronous</a>
--   <a>Api</a> messages.
--   
--   An observer consists of a filter and a process id. The filter converts
--   an observation to a message understood by the observer process, and
--   the <a>ProcessId</a> is used to send the message.
data Observer o
[Observer] :: (Show (Server p), Typeable p, Typeable o) => (o -> Maybe (Api p  'Asynchronous)) -> Server p -> Observer o

-- | And an <a>Observer</a> to the set of reciepients for all observations
--   reported by <a>observed</a>. Note that the observers are keyed by the
--   observing process, i.e. a previous entry for the process contained in
--   the <a>Observer</a> is overwritten. If you want multiple entries for a
--   single process, just combine several filter functions.
registerObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Send the <a>ForgetObserver</a> message
forgetObserver :: (SetMember Process (Process q) r, HasCallStack, Member Interrupts r, Typeable o) => Observer o -> Server (ObserverRegistry o) -> Eff r ()

-- | Based on the <a>Api</a> instance for <a>Observer</a> this simplified
--   writing a callback handler for observations. In order to register to
--   and <a>ObserverRegistry</a> use <a>toObserver</a>.
handleObservations :: (HasCallStack, Typeable o, SetMember Process (Process q) r) => (o -> Eff r CallbackResult) -> MessageCallback (Observer o) r

-- | Use a <a>Server</a> as an <a>Observer</a> for
--   <a>handleObservations</a>.
toObserver :: Typeable o => Server (Observer o) -> Observer o

-- | Create an <a>Observer</a> that conditionally accepts all observations
--   of the given type and applies the given function to them; the function
--   takes an observation and returns an <a>Api</a> cast that the observer
--   server is compatible to.
toObserverFor :: (Typeable a, Typeable o) => (o -> Api a  'Asynchronous) -> Server a -> Observer o

-- | Provide the implementation for the <a>ObserverRegistry</a> Api, this
--   handled <a>RegisterObserver</a> and <a>ForgetObserver</a> messages. It
--   also adds the <a>ObserverState</a> constraint to the effect list.
handleObserverRegistration :: forall o q r. (HasCallStack, Typeable o, SetMember Process (Process q) r, Member (ObserverState o) r) => MessageCallback (ObserverRegistry o) r

-- | Keep track of registered <a>Observer</a>s.
--   
--   Handle the <a>ObserverState</a> introduced by
--   <a>handleObserverRegistration</a>.
manageObservers :: Eff (ObserverState o : r) a -> Eff r a

-- | Report an observation to all observers. The process needs to
--   <a>manageObservers</a> and to <a>handleObserverRegistration</a>.
observed :: forall o r q. (SetMember Process (Process q) r, Member (ObserverState o) r, Member Interrupts r) => o -> Eff r ()

-- | A <a>Reader</a> for an <a>ObservationQueue</a>.
type ObservationQueueReader a = Reader (ObservationQueue a)

-- | Contains a <a>TBQueue</a> capturing observations. See
--   <a>spawnLinkObservationQueueWriter</a>, <a>readObservationQueue</a>.
data ObservationQueue a

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. This blocks
--   until something was captured or an interrupt or exceptions was thrown.
--   For a non-blocking variant use <a>tryReadObservationQueue</a> or
--   <a>flushObservationQueue</a>.
readObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r o

-- | Read queued observations captured and enqueued in the shared
--   <a>TBQueue</a> by <a>spawnLinkObservationQueueWriter</a>. Return the
--   oldest enqueued observation immediately or <a>Nothing</a> if the queue
--   is empty. Use <a>readObservationQueue</a> to block until an
--   observation is observed.
tryReadObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r (Maybe o)

-- | Read at once all currently queued observations captured and enqueued
--   in the shared <a>TBQueue</a> by
--   <a>spawnLinkObservationQueueWriter</a>. This returns immediately all
--   currently enqueued observations. For a blocking variant use
--   <a>readObservationQueue</a>.
flushObservationQueue :: forall o r. (Member (ObservationQueueReader o) r, HasCallStack, MonadIO (Eff r), Typeable o, Member Logs r) => Eff r [o]

-- | Create a mutable queue for observations. Use
--   <a>spawnLinkObservationQueueWriter</a> for a simple way to get a
--   process that enqueues all observations.
--   
--   <h4><b>Example</b></h4>
--   
--   <pre>
--   withObservationQueue 100 $ do
--     q  &lt;- ask @(ObservationQueueReader TestEvent)
--     wq &lt;- spawnLinkObservationQueueWriter q
--     registerObserver wq testServer
--     ...
--     cast testServer DoSomething
--     evt &lt;- readObservationQueue @TestEvent
--     ...
--   </pre>
withObservationQueue :: forall o b e len. (HasCallStack, Typeable o, Show o, Member Logs e, Lifted IO e, Integral len, Member Interrupts e) => len -> Eff (ObservationQueueReader o : e) b -> Eff e b

-- | Spawn a process that can be used as an <a>Observer</a> that enqueues
--   the observations into an <a>ObservationQueue</a>. See
--   <a>withObservationQueue</a> for an example.
--   
--   The observations can be obtained by <a>readObservationQueue</a>. All
--   observations are captured up to the queue size limit, such that the
--   first message received will be first message returned by
--   <a>readObservationQueue</a>.
spawnLinkObservationQueueWriter :: forall o q. (Typeable o, Show o, Member Logs q, Lifted IO q, HasCallStack) => ObservationQueue o -> Eff (InterruptableProcess q) (Observer o)

-- | The concrete list of <a>Eff</a>ects for this scheduler implementation.
type SchedulerIO = (Reader SchedulerState : LoggingAndIo)

-- | Type class constraint to indicate that an effect union contains the
--   effects required by every process and the scheduler implementation
--   itself.
type HasSchedulerIO r = (HasCallStack, Lifted IO r, SchedulerIO <:: r)

-- | The concrete list of the effects, that the <a>Process</a> uses
type InterruptableProcEff = InterruptableProcess SchedulerIO

-- | The concrete list of <a>Eff</a>ects of processes compatible with this
--   scheduler. This builds upon <a>SchedulerIO</a>.
type ProcEff = ConsProcess SchedulerIO

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMain :: HasCallStack => Eff InterruptableProcEff () -> IO ()

-- | Start the message passing concurrency system then execute a
--   <a>Process</a> on top of <a>SchedulerIO</a> effect. All logging is
--   sent to standard output.
defaultMainWithLogWriter :: HasCallStack => LogWriter IO -> Eff InterruptableProcEff () -> IO ()

-- | This is the main entry point to running a message passing concurrency
--   application. This function takes a <a>Process</a> on top of the
--   <a>SchedulerIO</a> effect for concurrent logging.
schedule :: HasCallStack => Eff InterruptableProcEff () -> Eff LoggingAndIo ()

-- | Like <a>scheduleIO</a> but <i>pure</i>. The <tt>yield</tt> effect is
--   just <tt>return ()</tt>. <tt>schedulePure == runIdentity .
--   <a>scheduleM</a> (Identity . run) (return ())</tt>
schedulePure :: Eff (InterruptableProcess '[Logs, LogWriterReader PureLogWriter]) a -> Either (ExitReason  'NoRecovery) a

-- | Execute a <a>Process</a> using <a>scheduleM</a> on top of <a>Lift</a>
--   <tt>IO</tt> and <a>withLogging</a> <tt>String</tt> effects.
defaultMainSingleThreaded :: HasCallStack => Eff (InterruptableProcess LoggingAndIo) () -> IO ()