RSAGL.FRP.FRP
- data FRP e m j p
- switchContinue :: FRP e m (Maybe (FRP e m (SwitchInputOf m) (SwitchOutputOf m)), SwitchInputOf m) (SwitchInputOf m)
- switchTerminate :: FRP e m (Maybe (FRP e m (SwitchInputOf m) (SwitchOutputOf m)), SwitchOutputOf m) (SwitchOutputOf m)
- spawnThreads :: ThreadingOf m ~ Enabled => FRP e m [(ThreadIDOf m, FRP e m (SwitchInputOf m) (SwitchOutputOf m))] ()
- killThreadIf :: ThreadingOf m ~ Enabled => FRP e m Bool ()
- threadIdentity :: FRP e m () (ThreadIDOf m)
- withThreadIdentity :: (ThreadIDOf m -> FRP e m j p) -> FRP e m j p
- frpTest :: (forall e. [FRP e (FRPX () () i o) i o]) -> [i] -> IO [[o]]
- type FRPProgram s i o = FRPInit s () i o
- newFRPProgram :: (RecombinantState s, Eq t) => ThreadIdentityRule t -> (forall e. [(t, FRP e (FRPX t s i o) i o)]) -> IO (FRPProgram s i [(t, o)])
- newFRP1Program :: (forall e. FRP e (FRP1 s i o) i o) -> IO (FRPProgram s i o)
- updateFRPProgram :: Maybe Time -> (i, s) -> FRPProgram s i o -> IO (o, s)
- accumulate :: p -> (j -> p -> p) -> FRP e m j p
- absoluteTime :: FRP e m () Time
- deltaTime :: FRP e m () Time
- type ThreadIdentityRule t = (t -> Bool) -> t -> Bool
- forbidDuplicates :: Eq t => ThreadIdentityRule t
- allowAnonymous :: ThreadIdentityRule t -> ThreadIdentityRule (Maybe t)
- nullaryThreadIdentity :: ThreadIdentityRule a
- frpContext :: (RecombinantState s, s ~ StateOf m, FRPModel m, Eq t) => ThreadIdentityRule t -> [(t, FRP e (FRPContext t j p m) j p)] -> FRP e m j [(t, p)]
- frp1Context :: FRPModel m => FRP e (FRP1Context j p m) j p -> FRP e m j p
- frpFix :: FRPModel m => FRP e (FRP1Context (j, x) (p, x) m) (j, x) (p, x) -> FRP e m j p
- whenJust :: FRPModel m => (forall x y. FRP e (FRP1Context x y m) j p) -> FRP e m (Maybe j) (Maybe p)
- ioInit :: InputOutputOf m ~ Enabled => IO p -> FRP e m () p
- ioAction :: InputOutputOf m ~ Enabled => (j -> IO p) -> FRP e m j p
- outgoingBy :: (j -> j -> Bool) -> FRP e m j (Message j)
- outgoing :: Eq j => FRP e m j (Message j)
- incoming :: FRP e m (Message j) j
- class StreamFunctor s where
- streampure :: a -> FRP e m () (s a)
- streammap :: (a -> b) -> FRP e m (s a) (s b)
- randomA :: Random a => FRP e m (a, a) a
Documentation
A switchable automata with timewise numerical methods.
switchContinue :: FRP e m (Maybe (FRP e m (SwitchInputOf m) (SwitchOutputOf m)), SwitchInputOf m) (SwitchInputOf m)Source
Whenever a value is provided, change the presently running switch (or thread) to the specified new value, and execute that switch before continuing. This destroys all state local to the currently running switch (or thread). This function acts as if the switch were performed at frame begin.
switchTerminate :: FRP e m (Maybe (FRP e m (SwitchInputOf m) (SwitchOutputOf m)), SwitchOutputOf m) (SwitchOutputOf m)Source
Whenever a value is provided, change the presently running switch (or thread) to the specified new value, and execute that switch before continuing. This destroys all state local to the currently running switch (or thread). This function acts as if the switch were performed at frame end.
spawnThreads :: ThreadingOf m ~ Enabled => FRP e m [(ThreadIDOf m, FRP e m (SwitchInputOf m) (SwitchOutputOf m))] ()Source
Spawn new threads once per frame.
killThreadIf :: ThreadingOf m ~ Enabled => FRP e m Bool ()Source
Kill the current thread, only when the given parameter is true.
threadIdentity :: FRP e m () (ThreadIDOf m)Source
Get the current thread's identity.
withThreadIdentity :: (ThreadIDOf m -> FRP e m j p) -> FRP e m j pSource
Construct an arrow from its thread identity.
type FRPProgram s i o = FRPInit s () i oSource
newFRPProgram :: (RecombinantState s, Eq t) => ThreadIdentityRule t -> (forall e. [(t, FRP e (FRPX t s i o) i o)]) -> IO (FRPProgram s i [(t, o)])Source
Construct a multi-threaded FRPProgram.
newFRP1Program :: (forall e. FRP e (FRP1 s i o) i o) -> IO (FRPProgram s i o)Source
Construct a single-threaded FRPProgram.
updateFRPProgram :: Maybe Time -> (i, s) -> FRPProgram s i o -> IO (o, s)Source
Bring an FRPProgram up-to-date with the current time or a specific time.
accumulate :: p -> (j -> p -> p) -> FRP e m j pSource
Framewise accumulation of signals. The embedded function recieves the current input and the previous output.
absoluteTime :: FRP e m () TimeSource
Get the current absolute time.
type ThreadIdentityRule t = (t -> Bool) -> t -> BoolSource
Should a thread be allowed to spawn? Typical values are nullaryThreadIdentity, forbidDuplicates.
The predicate tests whether or not a particular thread is already running.
forbidDuplicates :: Eq t => ThreadIdentityRule tSource
Forbig duplicate threads by equality on the thread identity.
allowAnonymous :: ThreadIdentityRule t -> ThreadIdentityRule (Maybe t)Source
Allow unlimited duplicate Nothing threads, while restricting all other threads according to the specified rule.
nullaryThreadIdentity :: ThreadIdentityRule aSource
Allow unlimited duplicate threads.
frpContext :: (RecombinantState s, s ~ StateOf m, FRPModel m, Eq t) => ThreadIdentityRule t -> [(t, FRP e (FRPContext t j p m) j p)] -> FRP e m j [(t, p)]Source
Embed some threads inside another running thread, as threadGroup.
frp1Context :: FRPModel m => FRP e (FRP1Context j p m) j p -> FRP e m j pSource
Embed a single-threaded, bracketed switch inside another running thread.
frpFix :: FRPModel m => FRP e (FRP1Context (j, x) (p, x) m) (j, x) (p, x) -> FRP e m j pSource
Value recusion (see fix).
whenJust :: FRPModel m => (forall x y. FRP e (FRP1Context x y m) j p) -> FRP e m (Maybe j) (Maybe p)Source
Run a computation only when the input is defined.
ioInit :: InputOutputOf m ~ Enabled => IO p -> FRP e m () pSource
Perform an IO action when a stream is first initialized.
ioAction :: InputOutputOf m ~ Enabled => (j -> IO p) -> FRP e m j pSource
Perform an arbitrary IO action.
Arguments
| :: (j -> j -> Bool) | Equality predicate as described in |
| -> FRP e m j (Message j) |
Send tagged information.