RSAGL.FRP.Message

A memoization scheme in which a piece of information is tagged with a unique identifier for its source. Messages can be combined, and the tagging information indicates the specific combination. On the receiving end, we memoize the single most recent incoming message, and reuse it if the source information matches.

Documentation

data Message a

A sourced packet of information.

Instances

StreamFunctor Message

consistent :: Message a -> Message b -> Bool

Two messages are consistent if they arrive from identical sources.

consistency :: Message a -> Message b -> Ordering

An arbitrary ordering scheme on messages.

peek :: Message a -> a

Examine a message without memoization.

data Transmitter a

An object that can memoize matching sequential outgoing messages.

newTransmitterBy :: (a -> a -> Bool) -> IO (Transmitter a)

newTransmitter :: Eq a => IO (Transmitter a)

Equivalent to newTransmitterBy (==).

data Receiver a

An object that can memoize sequentially matching incoming messages.

newReceiver :: IO (Receiver a)

(<<*>>) :: Message (a -> b) -> Message a -> Message b

Bind two messages.

send :: a -> IO (Message a)

Construct a new message from a one-time source.

receive :: Receiver a -> Message a -> IO a

Memoizes an incomming message stream.

transmit :: Transmitter a -> a -> IO (Message a)

Tags an outgoing stream for memoization.