Control.Concurrent.Chan.Extra

Documentation

class ChanScoped (c :: Scope -> * -> *) where

Class for changing the access of a typed channel

Methods

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

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

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

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

Instances

ChanScoped ChanRW

Defined in Control.Concurrent.Chan.Extra

Methods

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

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

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

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

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

type DiffNanosec = Int

class ChanExtra (inputC :: * -> *) (outputC :: * -> *) | inputC -> outputC, outputC -> inputC where

Class for extra channel techniques

Methods

debounceStatic

Arguments

:: DiffNanosec

Time to wait before attempting to send the message

-> outputC a

-> IO (inputC a, Async ())

Throw away messages that meet the threshold

throttleStatic

Arguments

:: DiffNanosec

Time to wait before sending the message, for every message

-> outputC a

-> IO (inputC a, Async ())

Refrain from relaying messages that meet the threshold

intersperseStatic

Arguments

:: DiffNanosec

Time to at-least wait to intersperse messages

-> IO a

Get a message to intersperse

-> outputC a

-> IO (inputC a, Async (), Async ())

Intercalate messages while threshold is met

Instances

ChanExtra Chan Chan

Defined in Control.Concurrent.Chan.Extra

Methods

debounceStatic :: DiffNanosec -> Chan a -> IO (Chan a, Async ())

throttleStatic :: DiffNanosec -> Chan a -> IO (Chan a, Async ())

intersperseStatic :: DiffNanosec -> IO a -> Chan a -> IO (Chan a, Async (), Async ())

ChanExtra TChan TChan

Defined in Control.Concurrent.Chan.Extra

Methods

debounceStatic :: DiffNanosec -> TChan a -> IO (TChan a, Async ())

throttleStatic :: DiffNanosec -> TChan a -> IO (TChan a, Async ())

intersperseStatic :: DiffNanosec -> IO a -> TChan a -> IO (TChan a, Async (), Async ())

ChanExtra (ChanRW Write) (ChanRW Read)

Defined in Control.Concurrent.Chan.Extra

Methods

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

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

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

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 ())