{-# LANGUAGE MonoLocalBinds #-}
{-# LANGUAGE TypeOperators #-}
{-# LANGUAGE TypeFamilies #-}
{-# LANGUAGE FlexibleContexts #-}
{-# OPTIONS_GHC -Wall -fno-warn-tabs #-}
module Control.Moffy (
Sig, ISig,
React, Rct, EvReqs, EvOccs, Request(..),
Firstable, Adjustable,
await, adjust, adjustSig, never,
emit, waitFor, repeat,
find, scanl,
first, at, break, until, indexBy,
spawn, parList ) where
import Prelude hiding (repeat, scanl, until, break)
import Control.Moffy.Internal.Sig (
adjustSig, at_, break_, until_, indexBy_, spawn, parList_ )
import Control.Moffy.Internal.Sig.Type (
Sig, ISig, emit, waitFor, repeat, find, scanl )
import Control.Moffy.Internal.React (Firstable, Adjustable, first_, adjust)
import Control.Moffy.Internal.React.Type (
React, Rct, EvReqs, EvOccs, Request(..), await, forkThreadId, never )
import Data.Type.Set ((:+:))
import Data.OneOrMore (Mergeable)
import Data.Or (Or)
infixr 8 `first`
first :: Firstable es es' a b =>
React s es a -> React s es' b -> React s (es :+: es') (Or a b)
first :: forall (es :: Set (*)) (es' :: Set (*)) a b s.
Firstable es es' a b =>
React s es a -> React s es' b -> React s (es :+: es') (Or a b)
first = forall (es :: Set (*)) (es' :: Set (*)) a b s.
Firstable es es' a b =>
React s (es :+: es') (ThreadId, ThreadId)
-> React s es a -> React s es' b -> React s (es :+: es') (Or a b)
first_ forall s (es :: Set (*)). React s es (ThreadId, ThreadId)
forkThreadId
infixr 7 `at`
at :: Firstable es es' (ISig s (es :+: es') a r) r' =>
Sig s es a r -> React s es' r' ->
React s (es :+: es') (Either r (Maybe a, r'))
at :: forall (es :: Set (*)) (es' :: Set (*)) s a r r'.
Firstable es es' (ISig s (es :+: es') a r) r' =>
Sig s es a r
-> React s es' r' -> React s (es :+: es') (Either r (Maybe a, r'))
at = forall (es :: Set (*)) (es' :: Set (*)) s a r r'.
Firstable es es' (ISig s (es :+: es') a r) r' =>
React s (es :+: es') (ThreadId, ThreadId)
-> Sig s es a r
-> React s es' r'
-> React s (es :+: es') (Either r (Maybe a, r'))
at_ forall s (es :: Set (*)). React s es (ThreadId, ThreadId)
forkThreadId
infixl 7 `break`, `until`
break :: Firstable es es' (ISig s (es :+: es') a r) r' =>
Sig s es a r -> React s es' r' ->
Sig s (es :+: es') a (Either r (Maybe a, r'))
break :: forall (es :: Set (*)) (es' :: Set (*)) s a r r'.
Firstable es es' (ISig s (es :+: es') a r) r' =>
Sig s es a r
-> React s es' r' -> Sig s (es :+: es') a (Either r (Maybe a, r'))
break = forall (es :: Set (*)) (es' :: Set (*)) s a r r'.
Firstable es es' (ISig s (es :+: es') a r) r' =>
React s (es :+: es') (ThreadId, ThreadId)
-> Sig s es a r
-> React s es' r'
-> Sig s (es :+: es') a (Either r (Maybe a, r'))
break_ forall s (es :: Set (*)). React s es (ThreadId, ThreadId)
forkThreadId
until :: Firstable es es' (ISig s (es :+: es') a r) r' =>
Sig s es a r -> React s es' r' ->
Sig s (es :+: es') a (Either r (a, r'))
until :: forall (es :: Set (*)) (es' :: Set (*)) s a r r'.
Firstable es es' (ISig s (es :+: es') a r) r' =>
Sig s es a r
-> React s es' r' -> Sig s (es :+: es') a (Either r (a, r'))
until = forall (es :: Set (*)) (es' :: Set (*)) s a r r'.
Firstable es es' (ISig s (es :+: es') a r) r' =>
React s (es :+: es') (ThreadId, ThreadId)
-> Sig s es a r
-> React s es' r'
-> Sig s (es :+: es') a (Either r (a, r'))
until_ forall s (es :: Set (*)). React s es (ThreadId, ThreadId)
forkThreadId
infixl 7 `indexBy`
indexBy ::
Firstable es es' (ISig s (es :+: es') a r) (ISig s (es :+: es') b r') =>
Sig s es a r -> Sig s es' b r' ->
Sig s (es :+: es') (a, b) (Either r (Maybe a, r'))
indexBy :: forall (es :: Set (*)) (es' :: Set (*)) s a r b r'.
Firstable
es es' (ISig s (es :+: es') a r) (ISig s (es :+: es') b r') =>
Sig s es a r
-> Sig s es' b r'
-> Sig s (es :+: es') (a, b) (Either r (Maybe a, r'))
indexBy = forall (es :: Set (*)) (es' :: Set (*)) s a r b r'.
Firstable
es es' (ISig s (es :+: es') a r) (ISig s (es :+: es') b r') =>
React s (es :+: es') (ThreadId, ThreadId)
-> Sig s es a r
-> Sig s es' b r'
-> Sig s (es :+: es') (a, b) (Either r (Maybe a, r'))
indexBy_ forall s (es :: Set (*)). React s es (ThreadId, ThreadId)
forkThreadId
parList :: ((es :+: es) ~ es, Mergeable es es es) =>
Sig s es (ISig s es a r) r' -> Sig s es [a] ([r], r')
parList :: forall (es :: Set (*)) s a r r'.
((es :+: es) ~ es, Mergeable es es es) =>
Sig s es (ISig s es a r) r' -> Sig s es [a] ([r], r')
parList = forall (es :: Set (*)) s a r r'.
((es :+: es) ~ es, Mergeable es es es) =>
React s es (ThreadId, ThreadId)
-> Sig s es (ISig s es a r) r' -> Sig s es [a] ([r], r')
parList_ forall s (es :: Set (*)). React s es (ThreadId, ThreadId)
forkThreadId