Events.GuardedChannels

GuardedEvents implements guarded events for channels.

Documentation

data GuardedChannel guard value

Instances

HasListen GuardedChannel

Guard guard => HasReceive (GuardedChannel guard)

HasSend (GuardedChannel guard)

type GQ guardQueue value = guardQueue (GuardInfo value)

type VQ valueQueue = valueQueue ValueInfo

newGuardedChannel :: HasGuardedChannel guardQueue valueQueue guard value => GQ guardQueue value -> VQ valueQueue -> IO (GuardedChannel guard value)

sneak :: Guard guard => GuardedChannel guard value -> GuardedEvent guard (Maybe value)

replace :: Guard guard => GuardedChannel guard value -> value -> GuardedEvent guard (Maybe value)

class HasEmpty xQueue where

Methods

newEmpty :: IO (xQueue xData)

Instances

HasEmpty NullGuardQueue

HasEmpty (NullValueQueue value)

Ord key => HasEmpty (EqGuardQueue key)

Ord key => HasEmpty (EqValueQueue key value)

class HasRemove yQueue x y where

Methods

remove :: yQueue yData -> x -> IO (Maybe (y, yData, IO (yQueue yData)), yQueue yData)

Instances

HasRemove NullGuardQueue value ()

HasRemove (NullValueQueue value) () value

Ord key => HasRemove (EqGuardQueue key) (key, value) (EqMatch key)

Ord key => HasRemove (EqValueQueue key value) (EqMatch key) (key, value)

class HasAdd xQueue x where

Methods

add :: xQueue xData -> x -> xData -> IO (xQueue xData, IO ())

Instances

HasAdd NullGuardQueue ()

HasAdd (NullValueQueue value) value

Ord key => HasAdd (EqGuardQueue key) (EqMatch key)

Ord key => HasAdd (EqValueQueue key value) (key, value)

class (HasRemove yQueue x y, HasAdd xQueue x) => CanSendX xQueue yQueue x y

Instances

(HasRemove yQueue x y, HasAdd xQueue x) => CanSendX xQueue yQueue x y

class (Guard guard, HasEmpty guardQueue, HasEmpty valueQueue, CanSendX guardQueue valueQueue guard value, CanSendX valueQueue guardQueue value guard) => HasGuardedChannel guardQueue valueQueue guard value

Instances

(Guard guard, HasEmpty guardQueue, HasEmpty valueQueue, CanSendX guardQueue valueQueue guard value, CanSendX valueQueue guardQueue value guard) => HasGuardedChannel guardQueue valueQueue guard value