Control.Monad.Aff.Bus

make :: forall a eff m. MonadEff (avar :: AVAR | eff) m => m (BusRW a)

Creates a new bidirectional Bus which can be read from and written to.

read :: forall r a eff. BusR' r a -> Aff (avar :: AVAR | eff) a

Blocks until a new value is pushed to the Bus, returning the value.

write :: forall r a eff. a -> BusW' r a -> Aff (avar :: AVAR | eff) Unit

Pushes a new value to the Bus, yieldig immediately.

split :: forall a. BusRW a -> Tuple (BusR a) (BusW a)

Splits a bidirectional Bus into separate read and write Buses.

kill :: forall r a eff. Error -> BusW' r a -> Aff (avar :: AVAR | eff) Unit

Kills the Bus and propagates the exception to all consumers.

data Cap

data Bus (r :: Row Type) a

type BusRW = Bus (read :: Cap, write :: Cap)

type BusR = BusR' ()

type BusR' r = Bus (read :: Cap | r)

type BusW = BusW' ()

type BusW' r = Bus (write :: Cap | r)