Control.Churro.Transport.MVar.Latest

MVar Transport Instance. New items overwrite the current queued item.

Useful in subscription-like contexts where you don't care about outdated values.

This is surprisingly useful since it doesn't block sources, but also doesn't accumulate items.

WARNING: Don't use if you want to ensure that all produced items are consumed!

Documentation

data Latest a

Instances

Transport Latest

Defined in Control.Churro.Transport.MVar.Latest

Associated Types

data In Latest :: Type -> Type

data Out Latest :: Type -> Type

Methods

flex :: IO (In Latest a, Out Latest a)

yank :: Out Latest a -> IO a

yeet :: In Latest a -> a -> IO ()

data In Latest a

Defined in Control.Churro.Transport.MVar.Latest

data In Latest a = ChanIn (MVar a)

data Out Latest a

Defined in Control.Churro.Transport.MVar.Latest

data Out Latest a = ChanOut (MVar a)

type ChurroLatest a = Churro a Latest

runWaitLatest :: ChurroLatest a Void Void -> IO a

Convenience function for running a Churro with a MVar backed Latest Transport.

runWaitListLatest :: ChurroLatest () Void o -> IO [o]

Convenience function for running a Churro into a List with a MVar backed Latest Transport.