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 Source #

Class for changing the access of a typed channel

Methods

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

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

Instances

ChanScoped ChanRW Source #
Instance details Defined in Control.Concurrent.Chan.Extra Methods readOnly :: Readable scope => ChanRW scope a -> ChanRW Read a Source # writeOnly :: Writable scope => ChanRW scope a -> ChanRW Write a Source # allowReading :: Writable scope => ChanRW scope a -> ChanRW ReadWrite a Source # allowWriting :: Readable scope => ChanRW scope a -> ChanRW ReadWrite a Source #
ChanScoped TChanRW Source #
Instance details Defined in Control.Concurrent.Chan.Extra Methods readOnly :: Readable scope => TChanRW scope a -> TChanRW Read a Source # writeOnly :: Writable scope => TChanRW scope a -> TChanRW Write a Source # allowReading :: Writable scope => TChanRW scope a -> TChanRW ReadWrite a Source # allowWriting :: Readable scope => TChanRW scope a -> TChanRW ReadWrite a Source #

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

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 Source #
Instance details Defined in Control.Concurrent.Chan.Extra Methods debounceStatic :: DiffNanosec -> Chan a -> IO (Chan a, Async ()) Source # throttleStatic :: DiffNanosec -> Chan a -> IO (Chan a, Async ()) Source # intersperseStatic :: DiffNanosec -> IO a -> Chan a -> IO (Chan a, Async (), Async ()) Source #
ChanExtra TChan TChan Source #
Instance details Defined in Control.Concurrent.Chan.Extra Methods debounceStatic :: DiffNanosec -> TChan a -> IO (TChan a, Async ()) Source # throttleStatic :: DiffNanosec -> TChan a -> IO (TChan a, Async ()) Source # intersperseStatic :: DiffNanosec -> IO a -> TChan a -> IO (TChan a, Async (), Async ()) Source #
ChanExtra (ChanRW Write) (ChanRW Read) Source #
Instance details Defined in Control.Concurrent.Chan.Extra Methods debounceStatic :: DiffNanosec -> ChanRW Read a -> IO (ChanRW Write a, Async ()) Source # throttleStatic :: DiffNanosec -> ChanRW Read a -> IO (ChanRW Write a, Async ()) Source # intersperseStatic :: DiffNanosec -> IO a -> ChanRW Read a -> IO (ChanRW Write a, Async (), Async ()) Source #
ChanExtra (TChanRW Write) (TChanRW Read) Source #
Instance details Defined in Control.Concurrent.Chan.Extra Methods debounceStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ()) Source # throttleStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ()) Source # intersperseStatic :: DiffNanosec -> IO a -> TChanRW Read a -> IO (TChanRW Write a, Async (), Async ()) Source #