| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Network.Mux.Bearer.AttenuatedChannel
Synopsis
- data AttenuatedChannel m = AttenuatedChannel {
- acRead ∷ m ByteString
- acWrite ∷ ByteString → m ()
- acClose ∷ m ()
- type Size = Int64
- data SuccessOrFailure
- data Attenuation = Attenuation {
- aReadAttenuation ∷ Time → Size → (DiffTime, SuccessOrFailure)
- aWriteAttenuation ∷ Maybe Int
- newConnectedAttenuatedChannelPair ∷ ∀ m. (MonadLabelledSTM m, MonadTime m, MonadTimer m, MonadThrow m, MonadThrow (STM m)) ⇒ Tracer m AttenuatedChannelTrace → Tracer m AttenuatedChannelTrace → Attenuation → Attenuation → STM m (AttenuatedChannel m, AttenuatedChannel m)
- attenuationChannelAsMuxBearer ∷ ∀ m. (MonadThrow m, MonadMonotonicTime m) ⇒ SDUSize → DiffTime → Tracer m MuxTrace → AttenuatedChannel m → MuxBearer m
- data AttenuatedChannelTrace
- resourceVanishedIOError ∷ String → String → IOError
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
MsgCloseis received, write side has to be closed explicitly.
Constructors
| AttenuatedChannel | |
Fields
| |
data SuccessOrFailure Source #
data Attenuation Source #
Attenuation of a channel.
Constructors
| Attenuation | |
Fields
| |
newConnectedAttenuatedChannelPair ∷ ∀ m. (MonadLabelledSTM m, MonadTime m, MonadTimer m, MonadThrow m, MonadThrow (STM m)) ⇒ Tracer m AttenuatedChannelTrace → Tracer m AttenuatedChannelTrace → Attenuation → Attenuation → STM m (AttenuatedChannel m, AttenuatedChannel m) Source #
Create a pair of connected AttenuatedChannels.
attenuationChannelAsMuxBearer ∷ ∀ m. (MonadThrow m, MonadMonotonicTime m) ⇒ SDUSize → DiffTime → Tracer m MuxTrace → AttenuatedChannel m → MuxBearer m Source #
Trace
data AttenuatedChannelTrace Source #
Constructors
| AttChannLocalClose Bool | |
| AttChannRemoteClose |