module Simulation.Aivika.Trans.Signal
(
Signal(..),
handleSignal_,
handleSignalComposite,
SignalSource,
newSignalSource,
newSignalSource0,
publishSignal,
triggerSignal,
mapSignal,
mapSignalM,
apSignal,
filterSignal,
filterSignal_,
filterSignalM,
filterSignalM_,
emptySignal,
merge2Signals,
merge3Signals,
merge4Signals,
merge5Signals,
arrivalSignal,
delaySignal,
delaySignalM,
SignalHistory,
signalHistorySignal,
newSignalHistory,
newSignalHistoryStartingWith,
readSignalHistory,
newSignalInTimes,
newSignalInIntegTimes,
newSignalInStartTime,
newSignalInStopTime,
newSignalInTimeGrid,
Signalable(..),
signalableChanged,
emptySignalable,
appendSignalable,
traceSignal) where
import Data.Monoid hiding ((<>))
import Data.Semigroup (Semigroup(..))
import Data.List.NonEmpty (NonEmpty((:|)))
import Data.List
import Data.Array
import Control.Monad
import Control.Monad.Trans
import Simulation.Aivika.Trans.Ref.Base
import Simulation.Aivika.Trans.DES
import Simulation.Aivika.Trans.Internal.Specs
import Simulation.Aivika.Trans.Internal.Parameter
import Simulation.Aivika.Trans.Internal.Simulation
import Simulation.Aivika.Trans.Internal.Dynamics
import Simulation.Aivika.Trans.Internal.Event
import Simulation.Aivika.Trans.Composite
import Simulation.Aivika.Arrival (Arrival(..))
data SignalSource m a =
SignalSource { forall (m :: * -> *) a. SignalSource m a -> Signal m a
publishSignal :: Signal m a,
forall (m :: * -> *) a. SignalSource m a -> a -> Event m ()
triggerSignal :: a -> Event m ()
}
data Signal m a =
Signal { forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
}
data SignalHandlerQueue m a =
SignalHandlerQueue { forall (m :: * -> *) a.
SignalHandlerQueue m a -> Ref m [SignalHandler m a]
queueList :: Ref m [SignalHandler m a] }
data SignalHandler m a =
SignalHandler { forall (m :: * -> *) a. SignalHandler m a -> a -> Event m ()
handlerComp :: a -> Event m (),
forall (m :: * -> *) a. SignalHandler m a -> Ref m ()
handlerRef :: Ref m () }
instance MonadDES m => Eq (SignalHandler m a) where
{-# INLINE (==) #-}
SignalHandler m a
x == :: SignalHandler m a -> SignalHandler m a -> Bool
== SignalHandler m a
y = (SignalHandler m a -> Ref m ()
forall (m :: * -> *) a. SignalHandler m a -> Ref m ()
handlerRef SignalHandler m a
x) Ref m () -> Ref m () -> Bool
forall a. Eq a => a -> a -> Bool
== (SignalHandler m a -> Ref m ()
forall (m :: * -> *) a. SignalHandler m a -> Ref m ()
handlerRef SignalHandler m a
y)
handleSignal_ :: MonadDES m => Signal m a -> (a -> Event m ()) -> Event m ()
{-# INLINE handleSignal_ #-}
handleSignal_ :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> (a -> Event m ()) -> Event m ()
handleSignal_ Signal m a
signal a -> Event m ()
h =
do DisposableEvent m
x <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
signal a -> Event m ()
h
() -> Event m ()
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return ()
handleSignalComposite :: MonadDES m => Signal m a -> (a -> Event m ()) -> Composite m ()
{-# INLINABLE handleSignalComposite #-}
handleSignalComposite :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> (a -> Event m ()) -> Composite m ()
handleSignalComposite Signal m a
signal a -> Event m ()
h =
do DisposableEvent m
x <- Event m (DisposableEvent m) -> Composite m (DisposableEvent m)
forall a. Event m a -> Composite m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
EventLift t m =>
Event m a -> t m a
liftEvent (Event m (DisposableEvent m) -> Composite m (DisposableEvent m))
-> Event m (DisposableEvent m) -> Composite m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
signal a -> Event m ()
h
DisposableEvent m -> Composite m ()
forall (m :: * -> *).
Monad m =>
DisposableEvent m -> Composite m ()
disposableComposite DisposableEvent m
x
newSignalSource :: MonadDES m => Simulation m (SignalSource m a)
{-# INLINABLE newSignalSource #-}
newSignalSource :: forall (m :: * -> *) a.
MonadDES m =>
Simulation m (SignalSource m a)
newSignalSource =
do Ref m [SignalHandler m a]
list <- [SignalHandler m a] -> Simulation m (Ref m [SignalHandler m a])
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef []
let queue :: SignalHandlerQueue m a
queue = SignalHandlerQueue { queueList :: Ref m [SignalHandler m a]
queueList = Ref m [SignalHandler m a]
list }
signal :: Signal m a
signal = Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = (a -> Event m ()) -> Event m (DisposableEvent m)
handle }
source :: SignalSource m a
source = SignalSource { publishSignal :: Signal m a
publishSignal = Signal m a
signal,
triggerSignal :: a -> Event m ()
triggerSignal = a -> Event m ()
trigger }
handle :: (a -> Event m ()) -> Event m (DisposableEvent m)
handle a -> Event m ()
h =
(Point m -> m (DisposableEvent m)) -> Event m (DisposableEvent m)
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m (DisposableEvent m)) -> Event m (DisposableEvent m))
-> (Point m -> m (DisposableEvent m))
-> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
do SignalHandler m a
x <- Point m -> Event m (SignalHandler m a) -> m (SignalHandler m a)
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m (SignalHandler m a) -> m (SignalHandler m a))
-> Event m (SignalHandler m a) -> m (SignalHandler m a)
forall a b. (a -> b) -> a -> b
$ SignalHandlerQueue m a
-> (a -> Event m ()) -> Event m (SignalHandler m a)
forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a
-> (a -> Event m ()) -> Event m (SignalHandler m a)
enqueueSignalHandler SignalHandlerQueue m a
queue a -> Event m ()
h
DisposableEvent m -> m (DisposableEvent m)
forall a. a -> m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> m (DisposableEvent m))
-> DisposableEvent m -> m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$
Event m () -> DisposableEvent m
forall (m :: * -> *). Event m () -> DisposableEvent m
DisposableEvent (Event m () -> DisposableEvent m)
-> Event m () -> DisposableEvent m
forall a b. (a -> b) -> a -> b
$
SignalHandlerQueue m a -> SignalHandler m a -> Event m ()
forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a -> SignalHandler m a -> Event m ()
dequeueSignalHandler SignalHandlerQueue m a
queue SignalHandler m a
x
trigger :: a -> Event m ()
trigger a
a =
SignalHandlerQueue m a -> a -> Event m ()
forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a -> a -> Event m ()
triggerSignalHandlers SignalHandlerQueue m a
queue a
a
SignalSource m a -> Simulation m (SignalSource m a)
forall a. a -> Simulation m a
forall (m :: * -> *) a. Monad m => a -> m a
return SignalSource m a
source
newSignalSource0 :: (MonadDES m, MonadRef0 m) => m (SignalSource m a)
{-# INLINABLE newSignalSource0 #-}
newSignalSource0 :: forall (m :: * -> *) a.
(MonadDES m, MonadRef0 m) =>
m (SignalSource m a)
newSignalSource0 =
do Ref m [SignalHandler m a]
list <- [SignalHandler m a] -> m (Ref m [SignalHandler m a])
forall a. a -> m (Ref m a)
forall (m :: * -> *) a. MonadRef0 m => a -> m (Ref m a)
newRef0 []
let queue :: SignalHandlerQueue m a
queue = SignalHandlerQueue { queueList :: Ref m [SignalHandler m a]
queueList = Ref m [SignalHandler m a]
list }
signal :: Signal m a
signal = Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = (a -> Event m ()) -> Event m (DisposableEvent m)
handle }
source :: SignalSource m a
source = SignalSource { publishSignal :: Signal m a
publishSignal = Signal m a
signal,
triggerSignal :: a -> Event m ()
triggerSignal = a -> Event m ()
trigger }
handle :: (a -> Event m ()) -> Event m (DisposableEvent m)
handle a -> Event m ()
h =
(Point m -> m (DisposableEvent m)) -> Event m (DisposableEvent m)
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m (DisposableEvent m)) -> Event m (DisposableEvent m))
-> (Point m -> m (DisposableEvent m))
-> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
do SignalHandler m a
x <- Point m -> Event m (SignalHandler m a) -> m (SignalHandler m a)
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m (SignalHandler m a) -> m (SignalHandler m a))
-> Event m (SignalHandler m a) -> m (SignalHandler m a)
forall a b. (a -> b) -> a -> b
$ SignalHandlerQueue m a
-> (a -> Event m ()) -> Event m (SignalHandler m a)
forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a
-> (a -> Event m ()) -> Event m (SignalHandler m a)
enqueueSignalHandler SignalHandlerQueue m a
queue a -> Event m ()
h
DisposableEvent m -> m (DisposableEvent m)
forall a. a -> m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> m (DisposableEvent m))
-> DisposableEvent m -> m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$
Event m () -> DisposableEvent m
forall (m :: * -> *). Event m () -> DisposableEvent m
DisposableEvent (Event m () -> DisposableEvent m)
-> Event m () -> DisposableEvent m
forall a b. (a -> b) -> a -> b
$
SignalHandlerQueue m a -> SignalHandler m a -> Event m ()
forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a -> SignalHandler m a -> Event m ()
dequeueSignalHandler SignalHandlerQueue m a
queue SignalHandler m a
x
trigger :: a -> Event m ()
trigger a
a =
SignalHandlerQueue m a -> a -> Event m ()
forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a -> a -> Event m ()
triggerSignalHandlers SignalHandlerQueue m a
queue a
a
SignalSource m a -> m (SignalSource m a)
forall a. a -> m a
forall (m :: * -> *) a. Monad m => a -> m a
return SignalSource m a
source
triggerSignalHandlers :: MonadDES m => SignalHandlerQueue m a -> a -> Event m ()
{-# INLINABLE triggerSignalHandlers #-}
triggerSignalHandlers :: forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a -> a -> Event m ()
triggerSignalHandlers SignalHandlerQueue m a
q a
a =
(Point m -> m ()) -> Event m ()
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m ()) -> Event m ())
-> (Point m -> m ()) -> Event m ()
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
do [SignalHandler m a]
hs <- Point m -> Event m [SignalHandler m a] -> m [SignalHandler m a]
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m [SignalHandler m a] -> m [SignalHandler m a])
-> Event m [SignalHandler m a] -> m [SignalHandler m a]
forall a b. (a -> b) -> a -> b
$ Ref m [SignalHandler m a] -> Event m [SignalHandler m a]
forall a. Ref m a -> Event m a
forall (m :: * -> *) a. MonadRef m => Ref m a -> Event m a
readRef (SignalHandlerQueue m a -> Ref m [SignalHandler m a]
forall (m :: * -> *) a.
SignalHandlerQueue m a -> Ref m [SignalHandler m a]
queueList SignalHandlerQueue m a
q)
[SignalHandler m a] -> (SignalHandler m a -> m ()) -> m ()
forall (t :: * -> *) (m :: * -> *) a b.
(Foldable t, Monad m) =>
t a -> (a -> m b) -> m ()
forM_ [SignalHandler m a]
hs ((SignalHandler m a -> m ()) -> m ())
-> (SignalHandler m a -> m ()) -> m ()
forall a b. (a -> b) -> a -> b
$ \SignalHandler m a
h ->
Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$ SignalHandler m a -> a -> Event m ()
forall (m :: * -> *) a. SignalHandler m a -> a -> Event m ()
handlerComp SignalHandler m a
h a
a
enqueueSignalHandler :: MonadDES m => SignalHandlerQueue m a -> (a -> Event m ()) -> Event m (SignalHandler m a)
{-# INLINABLE enqueueSignalHandler #-}
enqueueSignalHandler :: forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a
-> (a -> Event m ()) -> Event m (SignalHandler m a)
enqueueSignalHandler SignalHandlerQueue m a
q a -> Event m ()
h =
(Point m -> m (SignalHandler m a)) -> Event m (SignalHandler m a)
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m (SignalHandler m a)) -> Event m (SignalHandler m a))
-> (Point m -> m (SignalHandler m a))
-> Event m (SignalHandler m a)
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
do Ref m ()
r <- Run m -> Simulation m (Ref m ()) -> m (Ref m ())
forall (m :: * -> *) a. Run m -> Simulation m a -> m a
invokeSimulation (Point m -> Run m
forall (m :: * -> *). Point m -> Run m
pointRun Point m
p) (Simulation m (Ref m ()) -> m (Ref m ()))
-> Simulation m (Ref m ()) -> m (Ref m ())
forall a b. (a -> b) -> a -> b
$ () -> Simulation m (Ref m ())
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef ()
let handler :: SignalHandler m a
handler = SignalHandler { handlerComp :: a -> Event m ()
handlerComp = a -> Event m ()
h,
handlerRef :: Ref m ()
handlerRef = Ref m ()
r }
Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$ Ref m [SignalHandler m a]
-> ([SignalHandler m a] -> [SignalHandler m a]) -> Event m ()
forall a. Ref m a -> (a -> a) -> Event m ()
forall (m :: * -> *) a.
MonadRef m =>
Ref m a -> (a -> a) -> Event m ()
modifyRef (SignalHandlerQueue m a -> Ref m [SignalHandler m a]
forall (m :: * -> *) a.
SignalHandlerQueue m a -> Ref m [SignalHandler m a]
queueList SignalHandlerQueue m a
q) (SignalHandler m a
handler SignalHandler m a -> [SignalHandler m a] -> [SignalHandler m a]
forall a. a -> [a] -> [a]
:)
SignalHandler m a -> m (SignalHandler m a)
forall a. a -> m a
forall (m :: * -> *) a. Monad m => a -> m a
return SignalHandler m a
handler
dequeueSignalHandler :: MonadDES m => SignalHandlerQueue m a -> SignalHandler m a -> Event m ()
{-# INLINABLE dequeueSignalHandler #-}
dequeueSignalHandler :: forall (m :: * -> *) a.
MonadDES m =>
SignalHandlerQueue m a -> SignalHandler m a -> Event m ()
dequeueSignalHandler SignalHandlerQueue m a
q SignalHandler m a
h =
Ref m [SignalHandler m a]
-> ([SignalHandler m a] -> [SignalHandler m a]) -> Event m ()
forall a. Ref m a -> (a -> a) -> Event m ()
forall (m :: * -> *) a.
MonadRef m =>
Ref m a -> (a -> a) -> Event m ()
modifyRef (SignalHandlerQueue m a -> Ref m [SignalHandler m a]
forall (m :: * -> *) a.
SignalHandlerQueue m a -> Ref m [SignalHandler m a]
queueList SignalHandlerQueue m a
q) (SignalHandler m a -> [SignalHandler m a] -> [SignalHandler m a]
forall a. Eq a => a -> [a] -> [a]
delete SignalHandler m a
h)
instance MonadDES m => Functor (Signal m) where
{-# INLINE fmap #-}
fmap :: forall a b. (a -> b) -> Signal m a -> Signal m b
fmap = (a -> b) -> Signal m a -> Signal m b
forall (m :: * -> *) a b.
MonadDES m =>
(a -> b) -> Signal m a -> Signal m b
mapSignal
instance MonadDES m => Semigroup (Signal m a) where
{-# INLINE (<>) #-}
<> :: Signal m a -> Signal m a -> Signal m a
(<>) = Signal m a -> Signal m a -> Signal m a
forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a
merge2Signals
{-# INLINABLE sconcat #-}
sconcat :: NonEmpty (Signal m a) -> Signal m a
sconcat (Signal m a
x1 :| []) = Signal m a
x1
sconcat (Signal m a
x1 :| [Signal m a
x2]) = Signal m a -> Signal m a -> Signal m a
forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a
merge2Signals Signal m a
x1 Signal m a
x2
sconcat (Signal m a
x1 :| [Signal m a
x2, Signal m a
x3]) = Signal m a -> Signal m a -> Signal m a -> Signal m a
forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a -> Signal m a
merge3Signals Signal m a
x1 Signal m a
x2 Signal m a
x3
sconcat (Signal m a
x1 :| [Signal m a
x2, Signal m a
x3, Signal m a
x4]) = Signal m a -> Signal m a -> Signal m a -> Signal m a -> Signal m a
forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a -> Signal m a -> Signal m a
merge4Signals Signal m a
x1 Signal m a
x2 Signal m a
x3 Signal m a
x4
sconcat (Signal m a
x1 :| [Signal m a
x2, Signal m a
x3, Signal m a
x4, Signal m a
x5]) = Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
forall (m :: * -> *) a.
MonadDES m =>
Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
merge5Signals Signal m a
x1 Signal m a
x2 Signal m a
x3 Signal m a
x4 Signal m a
x5
sconcat (Signal m a
x1 :| (Signal m a
x2 : Signal m a
x3 : Signal m a
x4 : Signal m a
x5 : [Signal m a]
xs)) =
NonEmpty (Signal m a) -> Signal m a
forall a. Semigroup a => NonEmpty a -> a
sconcat (NonEmpty (Signal m a) -> Signal m a)
-> NonEmpty (Signal m a) -> Signal m a
forall a b. (a -> b) -> a -> b
$ Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
forall (m :: * -> *) a.
MonadDES m =>
Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
merge5Signals Signal m a
x1 Signal m a
x2 Signal m a
x3 Signal m a
x4 Signal m a
x5 Signal m a -> [Signal m a] -> NonEmpty (Signal m a)
forall a. a -> [a] -> NonEmpty a
:| [Signal m a]
xs
instance MonadDES m => Monoid (Signal m a) where
{-# INLINE mempty #-}
mempty :: Signal m a
mempty = Signal m a
forall (m :: * -> *) a. MonadDES m => Signal m a
emptySignal
{-# INLINE mappend #-}
mappend :: Signal m a -> Signal m a -> Signal m a
mappend = Signal m a -> Signal m a -> Signal m a
forall a. Semigroup a => a -> a -> a
(<>)
{-# INLINABLE mconcat #-}
mconcat :: [Signal m a] -> Signal m a
mconcat [] = Signal m a
forall a. Monoid a => a
mempty
mconcat (Signal m a
h:[Signal m a]
t) = NonEmpty (Signal m a) -> Signal m a
forall a. Semigroup a => NonEmpty a -> a
sconcat (Signal m a
h Signal m a -> [Signal m a] -> NonEmpty (Signal m a)
forall a. a -> [a] -> NonEmpty a
:| [Signal m a]
t)
mapSignal :: MonadDES m => (a -> b) -> Signal m a -> Signal m b
{-# INLINABLE mapSignal #-}
mapSignal :: forall (m :: * -> *) a b.
MonadDES m =>
(a -> b) -> Signal m a -> Signal m b
mapSignal a -> b
f Signal m a
m =
Signal { handleSignal :: (b -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \b -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ b -> Event m ()
h (b -> Event m ()) -> (a -> b) -> a -> Event m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> b
f }
filterSignal :: MonadDES m => (a -> Bool) -> Signal m a -> Signal m a
{-# INLINABLE filterSignal #-}
filterSignal :: forall (m :: * -> *) a.
MonadDES m =>
(a -> Bool) -> Signal m a -> Signal m a
filterSignal a -> Bool
p Signal m a
m =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
Bool -> Event m () -> Event m ()
forall (f :: * -> *). Applicative f => Bool -> f () -> f ()
when (a -> Bool
p a
a) (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ a -> Event m ()
h a
a }
filterSignal_ :: MonadDES m => (a -> Bool) -> Signal m a -> Signal m ()
{-# INLINABLE filterSignal_ #-}
filterSignal_ :: forall (m :: * -> *) a.
MonadDES m =>
(a -> Bool) -> Signal m a -> Signal m ()
filterSignal_ a -> Bool
p Signal m a
m =
Signal { handleSignal :: (() -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \() -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
Bool -> Event m () -> Event m ()
forall (f :: * -> *). Applicative f => Bool -> f () -> f ()
when (a -> Bool
p a
a) (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ () -> Event m ()
h () }
filterSignalM :: MonadDES m => (a -> Event m Bool) -> Signal m a -> Signal m a
{-# INLINABLE filterSignalM #-}
filterSignalM :: forall (m :: * -> *) a.
MonadDES m =>
(a -> Event m Bool) -> Signal m a -> Signal m a
filterSignalM a -> Event m Bool
p Signal m a
m =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
do Bool
x <- a -> Event m Bool
p a
a
Bool -> Event m () -> Event m ()
forall (f :: * -> *). Applicative f => Bool -> f () -> f ()
when Bool
x (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ a -> Event m ()
h a
a }
filterSignalM_ :: MonadDES m => (a -> Event m Bool) -> Signal m a -> Signal m ()
{-# INLINABLE filterSignalM_ #-}
filterSignalM_ :: forall (m :: * -> *) a.
MonadDES m =>
(a -> Event m Bool) -> Signal m a -> Signal m ()
filterSignalM_ a -> Event m Bool
p Signal m a
m =
Signal { handleSignal :: (() -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \() -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
do Bool
x <- a -> Event m Bool
p a
a
Bool -> Event m () -> Event m ()
forall (f :: * -> *). Applicative f => Bool -> f () -> f ()
when Bool
x (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ () -> Event m ()
h () }
merge2Signals :: MonadDES m => Signal m a -> Signal m a -> Signal m a
{-# INLINABLE merge2Signals #-}
merge2Signals :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a
merge2Signals Signal m a
m1 Signal m a
m2 =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
do DisposableEvent m
x1 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m1 a -> Event m ()
h
DisposableEvent m
x2 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m2 a -> Event m ()
h
DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> Event m (DisposableEvent m))
-> DisposableEvent m -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ DisposableEvent m
x1 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x2 }
merge3Signals :: MonadDES m => Signal m a -> Signal m a -> Signal m a -> Signal m a
{-# INLINABLE merge3Signals #-}
merge3Signals :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a -> Signal m a
merge3Signals Signal m a
m1 Signal m a
m2 Signal m a
m3 =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
do DisposableEvent m
x1 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m1 a -> Event m ()
h
DisposableEvent m
x2 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m2 a -> Event m ()
h
DisposableEvent m
x3 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m3 a -> Event m ()
h
DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> Event m (DisposableEvent m))
-> DisposableEvent m -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ DisposableEvent m
x1 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x2 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x3 }
merge4Signals :: MonadDES m
=> Signal m a -> Signal m a -> Signal m a
-> Signal m a -> Signal m a
{-# INLINABLE merge4Signals #-}
merge4Signals :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m a -> Signal m a -> Signal m a -> Signal m a
merge4Signals Signal m a
m1 Signal m a
m2 Signal m a
m3 Signal m a
m4 =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
do DisposableEvent m
x1 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m1 a -> Event m ()
h
DisposableEvent m
x2 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m2 a -> Event m ()
h
DisposableEvent m
x3 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m3 a -> Event m ()
h
DisposableEvent m
x4 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m4 a -> Event m ()
h
DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> Event m (DisposableEvent m))
-> DisposableEvent m -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ DisposableEvent m
x1 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x2 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x3 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x4 }
merge5Signals :: MonadDES m
=> Signal m a -> Signal m a -> Signal m a
-> Signal m a -> Signal m a -> Signal m a
{-# INLINABLE merge5Signals #-}
merge5Signals :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
-> Signal m a
merge5Signals Signal m a
m1 Signal m a
m2 Signal m a
m3 Signal m a
m4 Signal m a
m5 =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
do DisposableEvent m
x1 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m1 a -> Event m ()
h
DisposableEvent m
x2 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m2 a -> Event m ()
h
DisposableEvent m
x3 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m3 a -> Event m ()
h
DisposableEvent m
x4 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m4 a -> Event m ()
h
DisposableEvent m
x5 <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m5 a -> Event m ()
h
DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> Event m (DisposableEvent m))
-> DisposableEvent m -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ DisposableEvent m
x1 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x2 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x3 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x4 DisposableEvent m -> DisposableEvent m -> DisposableEvent m
forall a. Semigroup a => a -> a -> a
<> DisposableEvent m
x5 }
mapSignalM :: MonadDES m => (a -> Event m b) -> Signal m a -> Signal m b
{-# INLINABLE mapSignalM #-}
mapSignalM :: forall (m :: * -> *) a b.
MonadDES m =>
(a -> Event m b) -> Signal m a -> Signal m b
mapSignalM a -> Event m b
f Signal m a
m =
Signal { handleSignal :: (b -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \b -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m (a -> Event m b
f (a -> Event m b) -> (b -> Event m ()) -> a -> Event m ()
forall (m :: * -> *) a b c.
Monad m =>
(a -> m b) -> (b -> m c) -> a -> m c
>=> b -> Event m ()
h) }
apSignal :: MonadDES m => Event m (a -> b) -> Signal m a -> Signal m b
{-# INLINABLE apSignal #-}
apSignal :: forall (m :: * -> *) a b.
MonadDES m =>
Event m (a -> b) -> Signal m a -> Signal m b
apSignal Event m (a -> b)
f Signal m a
m =
Signal { handleSignal :: (b -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \b -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a -> do { a -> b
x <- Event m (a -> b)
f; b -> Event m ()
h (a -> b
x a
a) } }
emptySignal :: MonadDES m => Signal m a
{-# INLINABLE emptySignal #-}
emptySignal :: forall (m :: * -> *) a. MonadDES m => Signal m a
emptySignal =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h -> DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return DisposableEvent m
forall a. Monoid a => a
mempty }
data SignalHistory m a =
SignalHistory { forall (m :: * -> *) a. SignalHistory m a -> Signal m a
signalHistorySignal :: Signal m a,
forall (m :: * -> *) a. SignalHistory m a -> Ref m [Double]
signalHistoryTimes :: Ref m [Double],
forall (m :: * -> *) a. SignalHistory m a -> Ref m [a]
signalHistoryValues :: Ref m [a] }
newSignalHistory :: MonadDES m => Signal m a -> Composite m (SignalHistory m a)
{-# INLINABLE newSignalHistory #-}
newSignalHistory :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Composite m (SignalHistory m a)
newSignalHistory =
Maybe a -> Signal m a -> Composite m (SignalHistory m a)
forall (m :: * -> *) a.
MonadDES m =>
Maybe a -> Signal m a -> Composite m (SignalHistory m a)
newSignalHistoryStartingWith Maybe a
forall a. Maybe a
Nothing
newSignalHistoryStartingWith :: MonadDES m => Maybe a -> Signal m a -> Composite m (SignalHistory m a)
{-# INLINABLE newSignalHistoryStartingWith #-}
newSignalHistoryStartingWith :: forall (m :: * -> *) a.
MonadDES m =>
Maybe a -> Signal m a -> Composite m (SignalHistory m a)
newSignalHistoryStartingWith Maybe a
init Signal m a
signal =
do Ref m [Double]
ts <- Simulation m (Ref m [Double]) -> Composite m (Ref m [Double])
forall a. Simulation m a -> Composite m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation (Simulation m (Ref m [Double]) -> Composite m (Ref m [Double]))
-> Simulation m (Ref m [Double]) -> Composite m (Ref m [Double])
forall a b. (a -> b) -> a -> b
$ [Double] -> Simulation m (Ref m [Double])
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef []
Ref m [a]
xs <- Simulation m (Ref m [a]) -> Composite m (Ref m [a])
forall a. Simulation m a -> Composite m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation (Simulation m (Ref m [a]) -> Composite m (Ref m [a]))
-> Simulation m (Ref m [a]) -> Composite m (Ref m [a])
forall a b. (a -> b) -> a -> b
$ [a] -> Simulation m (Ref m [a])
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef []
case Maybe a
init of
Maybe a
Nothing -> () -> Composite m ()
forall a. a -> Composite m a
forall (m :: * -> *) a. Monad m => a -> m a
return ()
Just a
a ->
Event m () -> Composite m ()
forall a. Event m a -> Composite m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
EventLift t m =>
Event m a -> t m a
liftEvent (Event m () -> Composite m ()) -> Event m () -> Composite m ()
forall a b. (a -> b) -> a -> b
$
do Double
t <- Dynamics m Double -> Event m Double
forall a. Dynamics m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
DynamicsLift t m =>
Dynamics m a -> t m a
liftDynamics Dynamics m Double
forall (m :: * -> *). Monad m => Dynamics m Double
time
Ref m [Double] -> ([Double] -> [Double]) -> Event m ()
forall a. Ref m a -> (a -> a) -> Event m ()
forall (m :: * -> *) a.
MonadRef m =>
Ref m a -> (a -> a) -> Event m ()
modifyRef Ref m [Double]
ts (Double
t Double -> [Double] -> [Double]
forall a. a -> [a] -> [a]
:)
Ref m [a] -> ([a] -> [a]) -> Event m ()
forall a. Ref m a -> (a -> a) -> Event m ()
forall (m :: * -> *) a.
MonadRef m =>
Ref m a -> (a -> a) -> Event m ()
modifyRef Ref m [a]
xs (a
a a -> [a] -> [a]
forall a. a -> [a] -> [a]
:)
Signal m a -> (a -> Event m ()) -> Composite m ()
forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> (a -> Event m ()) -> Composite m ()
handleSignalComposite Signal m a
signal ((a -> Event m ()) -> Composite m ())
-> (a -> Event m ()) -> Composite m ()
forall a b. (a -> b) -> a -> b
$ \a
a ->
do Double
t <- Dynamics m Double -> Event m Double
forall a. Dynamics m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
DynamicsLift t m =>
Dynamics m a -> t m a
liftDynamics Dynamics m Double
forall (m :: * -> *). Monad m => Dynamics m Double
time
Ref m [Double] -> ([Double] -> [Double]) -> Event m ()
forall a. Ref m a -> (a -> a) -> Event m ()
forall (m :: * -> *) a.
MonadRef m =>
Ref m a -> (a -> a) -> Event m ()
modifyRef Ref m [Double]
ts (Double
t Double -> [Double] -> [Double]
forall a. a -> [a] -> [a]
:)
Ref m [a] -> ([a] -> [a]) -> Event m ()
forall a. Ref m a -> (a -> a) -> Event m ()
forall (m :: * -> *) a.
MonadRef m =>
Ref m a -> (a -> a) -> Event m ()
modifyRef Ref m [a]
xs (a
a a -> [a] -> [a]
forall a. a -> [a] -> [a]
:)
SignalHistory m a -> Composite m (SignalHistory m a)
forall a. a -> Composite m a
forall (m :: * -> *) a. Monad m => a -> m a
return SignalHistory { signalHistorySignal :: Signal m a
signalHistorySignal = Signal m a
signal,
signalHistoryTimes :: Ref m [Double]
signalHistoryTimes = Ref m [Double]
ts,
signalHistoryValues :: Ref m [a]
signalHistoryValues = Ref m [a]
xs }
readSignalHistory :: MonadDES m => SignalHistory m a -> Event m (Array Int Double, Array Int a)
{-# INLINABLE readSignalHistory #-}
readSignalHistory :: forall (m :: * -> *) a.
MonadDES m =>
SignalHistory m a -> Event m (Array Int Double, Array Int a)
readSignalHistory SignalHistory m a
history =
do [Double]
xs0 <- Ref m [Double] -> Event m [Double]
forall a. Ref m a -> Event m a
forall (m :: * -> *) a. MonadRef m => Ref m a -> Event m a
readRef (SignalHistory m a -> Ref m [Double]
forall (m :: * -> *) a. SignalHistory m a -> Ref m [Double]
signalHistoryTimes SignalHistory m a
history)
[a]
ys0 <- Ref m [a] -> Event m [a]
forall a. Ref m a -> Event m a
forall (m :: * -> *) a. MonadRef m => Ref m a -> Event m a
readRef (SignalHistory m a -> Ref m [a]
forall (m :: * -> *) a. SignalHistory m a -> Ref m [a]
signalHistoryValues SignalHistory m a
history)
let n :: Int
n = [Double] -> Int
forall a. [a] -> Int
forall (t :: * -> *) a. Foldable t => t a -> Int
length [Double]
xs0
xs :: Array Int Double
xs = (Int, Int) -> [Double] -> Array Int Double
forall i e. Ix i => (i, i) -> [e] -> Array i e
listArray (Int
0, Int
n Int -> Int -> Int
forall a. Num a => a -> a -> a
- Int
1) ([Double] -> [Double]
forall a. [a] -> [a]
reverse [Double]
xs0)
ys :: Array Int a
ys = (Int, Int) -> [a] -> Array Int a
forall i e. Ix i => (i, i) -> [e] -> Array i e
listArray (Int
0, Int
n Int -> Int -> Int
forall a. Num a => a -> a -> a
- Int
1) ([a] -> [a]
forall a. [a] -> [a]
reverse [a]
ys0)
(Array Int Double, Array Int a)
-> Event m (Array Int Double, Array Int a)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (Array Int Double
xs, Array Int a
ys)
triggerSignalWithCurrentTime :: MonadDES m => SignalSource m Double -> Event m ()
{-# INLINABLE triggerSignalWithCurrentTime #-}
triggerSignalWithCurrentTime :: forall (m :: * -> *).
MonadDES m =>
SignalSource m Double -> Event m ()
triggerSignalWithCurrentTime SignalSource m Double
s =
(Point m -> m ()) -> Event m ()
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m ()) -> Event m ())
-> (Point m -> m ()) -> Event m ()
forall a b. (a -> b) -> a -> b
$ \Point m
p -> Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Double -> Event m ()
forall (m :: * -> *) a. SignalSource m a -> a -> Event m ()
triggerSignal SignalSource m Double
s (Point m -> Double
forall (m :: * -> *). Point m -> Double
pointTime Point m
p)
newSignalInTimes :: MonadDES m => [Double] -> Event m (Signal m Double)
{-# INLINABLE newSignalInTimes #-}
newSignalInTimes :: forall (m :: * -> *).
MonadDES m =>
[Double] -> Event m (Signal m Double)
newSignalInTimes [Double]
xs =
do SignalSource m Double
s <- Simulation m (SignalSource m Double)
-> Event m (SignalSource m Double)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation Simulation m (SignalSource m Double)
forall (m :: * -> *) a.
MonadDES m =>
Simulation m (SignalSource m a)
newSignalSource
[Double] -> Event m () -> Event m ()
forall (m :: * -> *).
MonadDES m =>
[Double] -> Event m () -> Event m ()
enqueueEventWithTimes [Double]
xs (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Event m ()
forall (m :: * -> *).
MonadDES m =>
SignalSource m Double -> Event m ()
triggerSignalWithCurrentTime SignalSource m Double
s
Signal m Double -> Event m (Signal m Double)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (Signal m Double -> Event m (Signal m Double))
-> Signal m Double -> Event m (Signal m Double)
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Signal m Double
forall (m :: * -> *) a. SignalSource m a -> Signal m a
publishSignal SignalSource m Double
s
newSignalInIntegTimes :: MonadDES m => Event m (Signal m Double)
{-# INLINABLE newSignalInIntegTimes #-}
newSignalInIntegTimes :: forall (m :: * -> *). MonadDES m => Event m (Signal m Double)
newSignalInIntegTimes =
do SignalSource m Double
s <- Simulation m (SignalSource m Double)
-> Event m (SignalSource m Double)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation Simulation m (SignalSource m Double)
forall (m :: * -> *) a.
MonadDES m =>
Simulation m (SignalSource m a)
newSignalSource
Event m () -> Event m ()
forall (m :: * -> *). MonadDES m => Event m () -> Event m ()
enqueueEventWithIntegTimes (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Event m ()
forall (m :: * -> *).
MonadDES m =>
SignalSource m Double -> Event m ()
triggerSignalWithCurrentTime SignalSource m Double
s
Signal m Double -> Event m (Signal m Double)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (Signal m Double -> Event m (Signal m Double))
-> Signal m Double -> Event m (Signal m Double)
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Signal m Double
forall (m :: * -> *) a. SignalSource m a -> Signal m a
publishSignal SignalSource m Double
s
newSignalInStartTime :: MonadDES m => Event m (Signal m Double)
{-# INLINABLE newSignalInStartTime #-}
newSignalInStartTime :: forall (m :: * -> *). MonadDES m => Event m (Signal m Double)
newSignalInStartTime =
do SignalSource m Double
s <- Simulation m (SignalSource m Double)
-> Event m (SignalSource m Double)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation Simulation m (SignalSource m Double)
forall (m :: * -> *) a.
MonadDES m =>
Simulation m (SignalSource m a)
newSignalSource
Double
t <- Parameter m Double -> Event m Double
forall a. Parameter m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
ParameterLift t m =>
Parameter m a -> t m a
liftParameter Parameter m Double
forall (m :: * -> *). Monad m => Parameter m Double
starttime
Double -> Event m () -> Event m ()
forall (m :: * -> *).
EventQueueing m =>
Double -> Event m () -> Event m ()
enqueueEvent Double
t (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Event m ()
forall (m :: * -> *).
MonadDES m =>
SignalSource m Double -> Event m ()
triggerSignalWithCurrentTime SignalSource m Double
s
Signal m Double -> Event m (Signal m Double)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (Signal m Double -> Event m (Signal m Double))
-> Signal m Double -> Event m (Signal m Double)
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Signal m Double
forall (m :: * -> *) a. SignalSource m a -> Signal m a
publishSignal SignalSource m Double
s
newSignalInStopTime :: MonadDES m => Event m (Signal m Double)
{-# INLINABLE newSignalInStopTime #-}
newSignalInStopTime :: forall (m :: * -> *). MonadDES m => Event m (Signal m Double)
newSignalInStopTime =
do SignalSource m Double
s <- Simulation m (SignalSource m Double)
-> Event m (SignalSource m Double)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation Simulation m (SignalSource m Double)
forall (m :: * -> *) a.
MonadDES m =>
Simulation m (SignalSource m a)
newSignalSource
Double
t <- Parameter m Double -> Event m Double
forall a. Parameter m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
ParameterLift t m =>
Parameter m a -> t m a
liftParameter Parameter m Double
forall (m :: * -> *). Monad m => Parameter m Double
stoptime
Double -> Event m () -> Event m ()
forall (m :: * -> *).
EventQueueing m =>
Double -> Event m () -> Event m ()
enqueueEvent Double
t (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Event m ()
forall (m :: * -> *).
MonadDES m =>
SignalSource m Double -> Event m ()
triggerSignalWithCurrentTime SignalSource m Double
s
Signal m Double -> Event m (Signal m Double)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (Signal m Double -> Event m (Signal m Double))
-> Signal m Double -> Event m (Signal m Double)
forall a b. (a -> b) -> a -> b
$ SignalSource m Double -> Signal m Double
forall (m :: * -> *) a. SignalSource m a -> Signal m a
publishSignal SignalSource m Double
s
newSignalInTimeGrid :: MonadDES m => Int -> Event m (Signal m Int)
{-# INLINABLE newSignalInTimeGrid #-}
newSignalInTimeGrid :: forall (m :: * -> *). MonadDES m => Int -> Event m (Signal m Int)
newSignalInTimeGrid Int
n =
do Specs m
sc <- Parameter m (Specs m) -> Event m (Specs m)
forall a. Parameter m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
ParameterLift t m =>
Parameter m a -> t m a
liftParameter Parameter m (Specs m)
forall (m :: * -> *). Monad m => Parameter m (Specs m)
simulationSpecs
SignalSource m Int
s <- Simulation m (SignalSource m Int) -> Event m (SignalSource m Int)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation Simulation m (SignalSource m Int)
forall (m :: * -> *) a.
MonadDES m =>
Simulation m (SignalSource m a)
newSignalSource
let loop :: [(Int, Double)] -> Event m ()
loop [] = () -> Event m ()
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return ()
loop ((Int
i, Double
t) : [(Int, Double)]
xs) = Double -> Event m () -> Event m ()
forall (m :: * -> *).
EventQueueing m =>
Double -> Event m () -> Event m ()
enqueueEvent Double
t (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$
do SignalSource m Int -> Int -> Event m ()
forall (m :: * -> *) a. SignalSource m a -> a -> Event m ()
triggerSignal SignalSource m Int
s Int
i
[(Int, Double)] -> Event m ()
loop [(Int, Double)]
xs
[(Int, Double)] -> Event m ()
loop ([(Int, Double)] -> Event m ()) -> [(Int, Double)] -> Event m ()
forall a b. (a -> b) -> a -> b
$ Specs m -> Int -> [(Int, Double)]
forall (m :: * -> *). Specs m -> Int -> [(Int, Double)]
timeGrid Specs m
sc Int
n
Signal m Int -> Event m (Signal m Int)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (Signal m Int -> Event m (Signal m Int))
-> Signal m Int -> Event m (Signal m Int)
forall a b. (a -> b) -> a -> b
$ SignalSource m Int -> Signal m Int
forall (m :: * -> *) a. SignalSource m a -> Signal m a
publishSignal SignalSource m Int
s
data Signalable m a =
Signalable { forall (m :: * -> *) a. Signalable m a -> Event m a
readSignalable :: Event m a,
forall (m :: * -> *) a. Signalable m a -> Signal m ()
signalableChanged_ :: Signal m ()
}
signalableChanged :: MonadDES m => Signalable m a -> Signal m a
{-# INLINABLE signalableChanged #-}
signalableChanged :: forall (m :: * -> *) a. MonadDES m => Signalable m a -> Signal m a
signalableChanged Signalable m a
x = (() -> Event m a) -> Signal m () -> Signal m a
forall (m :: * -> *) a b.
MonadDES m =>
(a -> Event m b) -> Signal m a -> Signal m b
mapSignalM (Event m a -> () -> Event m a
forall a b. a -> b -> a
const (Event m a -> () -> Event m a) -> Event m a -> () -> Event m a
forall a b. (a -> b) -> a -> b
$ Signalable m a -> Event m a
forall (m :: * -> *) a. Signalable m a -> Event m a
readSignalable Signalable m a
x) (Signal m () -> Signal m a) -> Signal m () -> Signal m a
forall a b. (a -> b) -> a -> b
$ Signalable m a -> Signal m ()
forall (m :: * -> *) a. Signalable m a -> Signal m ()
signalableChanged_ Signalable m a
x
instance Functor m => Functor (Signalable m) where
{-# INLINE fmap #-}
fmap :: forall a b. (a -> b) -> Signalable m a -> Signalable m b
fmap a -> b
f Signalable m a
x = Signalable m a
x { readSignalable = fmap f (readSignalable x) }
instance (MonadDES m, Semigroup a) => Semigroup (Signalable m a) where
{-# INLINE (<>) #-}
<> :: Signalable m a -> Signalable m a -> Signalable m a
(<>) = Signalable m a -> Signalable m a -> Signalable m a
forall (m :: * -> *) a.
(MonadDES m, Semigroup a) =>
Signalable m a -> Signalable m a -> Signalable m a
appendSignalable
instance (MonadDES m, Monoid a, Semigroup a) => Monoid (Signalable m a) where
{-# INLINE mempty #-}
mempty :: Signalable m a
mempty = Signalable m a
forall (m :: * -> *) a. (MonadDES m, Monoid a) => Signalable m a
emptySignalable
{-# INLINE mappend #-}
mappend :: Signalable m a -> Signalable m a -> Signalable m a
mappend = Signalable m a -> Signalable m a -> Signalable m a
forall a. Semigroup a => a -> a -> a
(<>)
emptySignalable :: (MonadDES m, Monoid a) => Signalable m a
{-# INLINABLE emptySignalable #-}
emptySignalable :: forall (m :: * -> *) a. (MonadDES m, Monoid a) => Signalable m a
emptySignalable =
Signalable { readSignalable :: Event m a
readSignalable = a -> Event m a
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return a
forall a. Monoid a => a
mempty,
signalableChanged_ :: Signal m ()
signalableChanged_ = Signal m ()
forall a. Monoid a => a
mempty }
appendSignalable :: (MonadDES m, Semigroup a) => Signalable m a -> Signalable m a -> Signalable m a
{-# INLINABLE appendSignalable #-}
appendSignalable :: forall (m :: * -> *) a.
(MonadDES m, Semigroup a) =>
Signalable m a -> Signalable m a -> Signalable m a
appendSignalable Signalable m a
m1 Signalable m a
m2 =
Signalable { readSignalable :: Event m a
readSignalable = (a -> a -> a) -> Event m a -> Event m a -> Event m a
forall (m :: * -> *) a1 a2 r.
Monad m =>
(a1 -> a2 -> r) -> m a1 -> m a2 -> m r
liftM2 a -> a -> a
forall a. Semigroup a => a -> a -> a
(<>) (Signalable m a -> Event m a
forall (m :: * -> *) a. Signalable m a -> Event m a
readSignalable Signalable m a
m1) (Signalable m a -> Event m a
forall (m :: * -> *) a. Signalable m a -> Event m a
readSignalable Signalable m a
m2),
signalableChanged_ :: Signal m ()
signalableChanged_ = (Signalable m a -> Signal m ()
forall (m :: * -> *) a. Signalable m a -> Signal m ()
signalableChanged_ Signalable m a
m1) Signal m () -> Signal m () -> Signal m ()
forall a. Semigroup a => a -> a -> a
<> (Signalable m a -> Signal m ()
forall (m :: * -> *) a. Signalable m a -> Signal m ()
signalableChanged_ Signalable m a
m2) }
arrivalSignal :: MonadDES m => Signal m a -> Signal m (Arrival a)
{-# INLINABLE arrivalSignal #-}
arrivalSignal :: forall (m :: * -> *) a.
MonadDES m =>
Signal m a -> Signal m (Arrival a)
arrivalSignal Signal m a
m =
Signal { handleSignal :: (Arrival a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \Arrival a -> Event m ()
h ->
do Ref m (Maybe Double)
r <- Simulation m (Ref m (Maybe Double))
-> Event m (Ref m (Maybe Double))
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation (Simulation m (Ref m (Maybe Double))
-> Event m (Ref m (Maybe Double)))
-> Simulation m (Ref m (Maybe Double))
-> Event m (Ref m (Maybe Double))
forall a b. (a -> b) -> a -> b
$ Maybe Double -> Simulation m (Ref m (Maybe Double))
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef Maybe Double
forall a. Maybe a
Nothing
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
(Point m -> m ()) -> Event m ()
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m ()) -> Event m ())
-> (Point m -> m ()) -> Event m ()
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
do Maybe Double
t0 <- Point m -> Event m (Maybe Double) -> m (Maybe Double)
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m (Maybe Double) -> m (Maybe Double))
-> Event m (Maybe Double) -> m (Maybe Double)
forall a b. (a -> b) -> a -> b
$ Ref m (Maybe Double) -> Event m (Maybe Double)
forall a. Ref m a -> Event m a
forall (m :: * -> *) a. MonadRef m => Ref m a -> Event m a
readRef Ref m (Maybe Double)
r
let t :: Double
t = Point m -> Double
forall (m :: * -> *). Point m -> Double
pointTime Point m
p
Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$ Ref m (Maybe Double) -> Maybe Double -> Event m ()
forall a. Ref m a -> a -> Event m ()
forall (m :: * -> *) a. MonadRef m => Ref m a -> a -> Event m ()
writeRef Ref m (Maybe Double)
r (Double -> Maybe Double
forall a. a -> Maybe a
Just Double
t)
Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$
Arrival a -> Event m ()
h Arrival { arrivalValue :: a
arrivalValue = a
a,
arrivalTime :: Double
arrivalTime = Double
t,
arrivalDelay :: Maybe Double
arrivalDelay =
case Maybe Double
t0 of
Maybe Double
Nothing -> Maybe Double
forall a. Maybe a
Nothing
Just Double
t0 -> Double -> Maybe Double
forall a. a -> Maybe a
Just (Double
t Double -> Double -> Double
forall a. Num a => a -> a -> a
- Double
t0) } }
delaySignal :: MonadDES m => Double -> Signal m a -> Signal m a
{-# INLINABLE delaySignal #-}
delaySignal :: forall (m :: * -> *) a.
MonadDES m =>
Double -> Signal m a -> Signal m a
delaySignal Double
delta Signal m a
m =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
do Ref m Bool
r <- Simulation m (Ref m Bool) -> Event m (Ref m Bool)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation (Simulation m (Ref m Bool) -> Event m (Ref m Bool))
-> Simulation m (Ref m Bool) -> Event m (Ref m Bool)
forall a b. (a -> b) -> a -> b
$ Bool -> Simulation m (Ref m Bool)
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef Bool
False
DisposableEvent m
h <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
(Point m -> m ()) -> Event m ()
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m ()) -> Event m ())
-> (Point m -> m ()) -> Event m ()
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$
Double -> Event m () -> Event m ()
forall (m :: * -> *).
EventQueueing m =>
Double -> Event m () -> Event m ()
enqueueEvent (Point m -> Double
forall (m :: * -> *). Point m -> Double
pointTime Point m
p Double -> Double -> Double
forall a. Num a => a -> a -> a
+ Double
delta) (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$
do Bool
x <- Ref m Bool -> Event m Bool
forall a. Ref m a -> Event m a
forall (m :: * -> *) a. MonadRef m => Ref m a -> Event m a
readRef Ref m Bool
r
Bool -> Event m () -> Event m ()
forall (f :: * -> *). Applicative f => Bool -> f () -> f ()
unless Bool
x (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ a -> Event m ()
h a
a
DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> Event m (DisposableEvent m))
-> DisposableEvent m -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ Event m () -> DisposableEvent m
forall (m :: * -> *). Event m () -> DisposableEvent m
DisposableEvent (Event m () -> DisposableEvent m)
-> Event m () -> DisposableEvent m
forall a b. (a -> b) -> a -> b
$
DisposableEvent m -> Event m ()
forall (m :: * -> *). DisposableEvent m -> Event m ()
disposeEvent DisposableEvent m
h Event m () -> Event m () -> Event m ()
forall a b. Event m a -> Event m b -> Event m b
forall (m :: * -> *) a b. Monad m => m a -> m b -> m b
>>
Ref m Bool -> Bool -> Event m ()
forall a. Ref m a -> a -> Event m ()
forall (m :: * -> *) a. MonadRef m => Ref m a -> a -> Event m ()
writeRef Ref m Bool
r Bool
True
}
delaySignalM :: MonadDES m => Event m Double -> Signal m a -> Signal m a
{-# INLINABLE delaySignalM #-}
delaySignalM :: forall (m :: * -> *) a.
MonadDES m =>
Event m Double -> Signal m a -> Signal m a
delaySignalM Event m Double
delta Signal m a
m =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
do Ref m Bool
r <- Simulation m (Ref m Bool) -> Event m (Ref m Bool)
forall a. Simulation m a -> Event m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
SimulationLift t m =>
Simulation m a -> t m a
liftSimulation (Simulation m (Ref m Bool) -> Event m (Ref m Bool))
-> Simulation m (Ref m Bool) -> Event m (Ref m Bool)
forall a b. (a -> b) -> a -> b
$ Bool -> Simulation m (Ref m Bool)
forall a. a -> Simulation m (Ref m a)
forall (m :: * -> *) a. MonadRef m => a -> Simulation m (Ref m a)
newRef Bool
False
DisposableEvent m
h <- Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ \a
a ->
(Point m -> m ()) -> Event m ()
forall (m :: * -> *) a. (Point m -> m a) -> Event m a
Event ((Point m -> m ()) -> Event m ())
-> (Point m -> m ()) -> Event m ()
forall a b. (a -> b) -> a -> b
$ \Point m
p ->
do Double
delta' <- Point m -> Event m Double -> m Double
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p Event m Double
delta
Point m -> Event m () -> m ()
forall (m :: * -> *) a. Point m -> Event m a -> m a
invokeEvent Point m
p (Event m () -> m ()) -> Event m () -> m ()
forall a b. (a -> b) -> a -> b
$
Double -> Event m () -> Event m ()
forall (m :: * -> *).
EventQueueing m =>
Double -> Event m () -> Event m ()
enqueueEvent (Point m -> Double
forall (m :: * -> *). Point m -> Double
pointTime Point m
p Double -> Double -> Double
forall a. Num a => a -> a -> a
+ Double
delta') (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$
do Bool
x <- Ref m Bool -> Event m Bool
forall a. Ref m a -> Event m a
forall (m :: * -> *) a. MonadRef m => Ref m a -> Event m a
readRef Ref m Bool
r
Bool -> Event m () -> Event m ()
forall (f :: * -> *). Applicative f => Bool -> f () -> f ()
unless Bool
x (Event m () -> Event m ()) -> Event m () -> Event m ()
forall a b. (a -> b) -> a -> b
$ a -> Event m ()
h a
a
DisposableEvent m -> Event m (DisposableEvent m)
forall a. a -> Event m a
forall (m :: * -> *) a. Monad m => a -> m a
return (DisposableEvent m -> Event m (DisposableEvent m))
-> DisposableEvent m -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ Event m () -> DisposableEvent m
forall (m :: * -> *). Event m () -> DisposableEvent m
DisposableEvent (Event m () -> DisposableEvent m)
-> Event m () -> DisposableEvent m
forall a b. (a -> b) -> a -> b
$
DisposableEvent m -> Event m ()
forall (m :: * -> *). DisposableEvent m -> Event m ()
disposeEvent DisposableEvent m
h Event m () -> Event m () -> Event m ()
forall a b. Event m a -> Event m b -> Event m b
forall (m :: * -> *) a b. Monad m => m a -> m b -> m b
>>
Ref m Bool -> Bool -> Event m ()
forall a. Ref m a -> a -> Event m ()
forall (m :: * -> *) a. MonadRef m => Ref m a -> a -> Event m ()
writeRef Ref m Bool
r Bool
True
}
traceSignal :: MonadDES m => String -> Signal m a -> Signal m a
{-# INLINABLE traceSignal #-}
traceSignal :: forall (m :: * -> *) a.
MonadDES m =>
String -> Signal m a -> Signal m a
traceSignal String
message Signal m a
m =
Signal { handleSignal :: (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal = \a -> Event m ()
h ->
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
forall (m :: * -> *) a.
Signal m a -> (a -> Event m ()) -> Event m (DisposableEvent m)
handleSignal Signal m a
m ((a -> Event m ()) -> Event m (DisposableEvent m))
-> (a -> Event m ()) -> Event m (DisposableEvent m)
forall a b. (a -> b) -> a -> b
$ String -> Event m () -> Event m ()
forall (m :: * -> *) a.
MonadDES m =>
String -> Event m a -> Event m a
traceEvent String
message (Event m () -> Event m ()) -> (a -> Event m ()) -> a -> Event m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Event m ()
h }