network-mux-0.1.0.0: Multiplexing library
Safe HaskellNone
LanguageHaskell2010

Network.Mux.Bearer.AttenuatedChannel

Contents

Synopsis

Documentation

data AttenuatedChannel m Source #

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 explicietly.

Constructors

AttenuatedChannel 

Fields

data Attenuation Source #

Attenuation of a channel.

newConnectedAttenuatedChannelPair ∷ ∀ m. (MonadLabelledSTM m, MonadTime m, MonadTimer m, MonadThrow m, MonadThrow (STM m)) ⇒ Tracer m AttenuatedChannelTrace → Tracer m AttenuatedChannelTraceAttenuationAttenuation → STM m (AttenuatedChannel m, AttenuatedChannel m) Source #

Create a pair of connected AttenuatedChannels.

attenuationChannelAsMuxBearer ∷ ∀ m. (MonadThrow m, MonadMonotonicTime m) ⇒ SDUSizeDiffTime → Tracer m MuxTraceAttenuatedChannel m → MuxBearer m Source #

Trace

Utils