Control.Concurrent.STM.TChan.Typed

Documentation

newtype TChanRW (scope :: Scope) a

Constructors

TChanRW (TChan a)

Instances

ChanScoped TChanRW

Defined in Control.Concurrent.Chan.Extra

Methods

readOnly :: Readable scope => TChanRW scope a -> TChanRW Read a

writeOnly :: Writable scope => TChanRW scope a -> TChanRW Write a

allowReading :: Writable scope => TChanRW scope a -> TChanRW ReadWrite a

allowWriting :: Readable scope => TChanRW scope a -> TChanRW ReadWrite a

ChanExtra (TChanRW Write) (TChanRW Read)

Defined in Control.Concurrent.Chan.Extra

Methods

debounceStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ())

throttleStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ())

intersperseStatic :: DiffNanosec -> IO a -> TChanRW Read a -> IO (TChanRW Write a, Async (), Async ())

newTChanRW :: STM (TChanRW ReadWrite a)

writeTChanRW :: Writable scope => TChanRW scope a -> a -> STM ()

unGetTChanRW :: Writable scope => TChanRW scope a -> a -> STM ()

isEmptyTChanRW :: Readable scope => TChanRW scope a -> STM Bool

readTChanRW :: Readable scope => TChanRW scope a -> STM a

tryReadTChanRW :: Readable scope => TChanRW scope a -> STM (Maybe a)

peekTChanRW :: Readable scope => TChanRW scope a -> STM a

tryPeekTChanRW :: Readable scope => TChanRW scope a -> STM (Maybe a)

newBroadcastTChanRW :: STM (TChanRW Write a)

dupTChanRW :: Writable scopeIn => Readable scopeOut => TChanRW scopeIn a -> STM (TChanRW scopeOut a)

cloneTChanRW :: Writable scopeIn => Readable scopeOut => TChanRW scopeIn a -> STM (TChanRW scopeOut a)