Modulenetwork-mux-0.11.0.0Haskell2010

Network.Mux.Bearer.AttenuatedChannel

6 types
5 values

Packagenetwork-mux-0.11.0.0
Exports11
LanguageHaskell2010
LicenceApache-2.0
SourceAttenuatedChannel.hs

datadata AttenuatedChannel (m :: Type -> Type)

An AttenuatedChannel supports:

attenuation applied after reading a message from QueueChannel;
two-way close handshake with 120s timeout. Read side is closed as soon as an internal MsgClose is received, write side has to be closed explicitly.

Constructors

AttenuatedChannel
- acRead :: m ByteString
- acWrite :: ByteString -> m ()
- acClose :: m ()

typetype Size = Int64

datadata SuccessOrFailure

Constructors

Success
Failure IOError

datadata Attenuation

Attenuation of a channel.

Constructors

Attenuation
- aReadAttenuation :: Time -> Size -> (DiffTime, SuccessOrFailure)
- aWriteAttenuation :: Maybe Int

datadata QueueChannel (m :: Type -> Type)

QueueChannel is the low level bearer used by the simulated snocket.

Each read / write queues can be closed independently. Read queue is closed once MsgClose is read from the queue; dually, write queue is closed once MsgClose is written.

valuenewAttenuatedChannel