RxHaskell-0.1: Reactive Extensions for Haskell

Safe HaskellSafe

Signal.Scheduled

Synopsis

Documentation

start :: Scheduler s => s -> (Subscriber s v -> SchedulerIO s ()) -> IO (Signal s v)Source

Starts a signal which executes action on s.

subscribeOn :: forall s t v. (Scheduler s, Scheduler t) => Signal s v -> t -> Signal t vSource

Returns a signal which subscribes to sig on scheduler sch.

deliverOn :: forall s t v. (Scheduler s, Scheduler t) => Signal s v -> t -> Signal t vSource

Returns a signal which delivers the events of sig on scheduler sch.

first :: forall s v. Scheduler s => Signal s v -> IO (Event v)Source

Synchronously waits for the signal to send an event.

class Scheduler s Source

Represents a queue of IO actions which can be executed in FIFO order.

data SchedulerIO s a Source

An IO computation that must be performed in a scheduler of type s.

Instances

Scheduler s => Monad (SchedulerIO s) 
Functor (SchedulerIO s) 
Scheduler s => Applicative (SchedulerIO s) 
Scheduler s => MonadIO (SchedulerIO s) 
(Scheduler s, Show v) => Show (SchedulerIO s v)

Unsafely executes a SchedulerIO action and shows the result. This is for DEBUGGING PURPOSES ONLY.

data Signal s v Source

A signal which will send values of type v on a scheduler of type s.