Safe Haskell	Safe
Language	Haskell2010

Control.Concurrent.Chan.Extra

Synopsis

class ChanScoped (c :: Scope -> * -> *) where
- 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
type DiffNanosec = Int
class ChanExtra (inputC :: * -> *) (outputC :: * -> *) | inputC -> outputC, outputC -> inputC where
- debounceStatic :: DiffNanosec -> outputC a -> IO (inputC a, Async ())
- throttleStatic :: DiffNanosec -> outputC a -> IO (inputC a, Async ())
- intersperseStatic :: DiffNanosec -> IO a -> outputC a -> IO (inputC a, Async (), Async ())

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 #
Instance details 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 #
Instance details 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 #

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

Class for extra channel techniques

Methods

Arguments

:: DiffNanosec	Time to wait before attempting to send the message
-> outputC a
-> IO (inputC a, Async ())

Throw away messages that meet the threshold

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

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 #
Instance details 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 #
Instance details 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) #
Instance details 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) #
Instance details 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 ()) #