AMQP10::Protocol::TransferCodec
Encoders and allocation-free decoders for the performatives on the per-message path: transfer, disposition and flow.
Constants
OUTCOME_SIZE = 3 + 1
Every outcome we emit is a descriptor followed by an empty list (list0).
Instance methods
continuation_transfer_performative_size(handle, more) : Int32
Sourceread_disposition(reader : IO::Memory) : DispositionView
ameba:disable Metrics/CyclomaticComplexity
transfer_performative_size(handle, delivery_id, delivery_tag, more, settled) : Int32
Sourcewrite_continuation_transfer_performative(io, handle, more) : Nil
Sourcewrite_disposition(io : IO, channel : UInt16, first : UInt32, outcome : Outcome, settled = true, role : Role = Role::Receiver, last : UInt32 | Nil = nil) : UInt64
Returns the number of bytes written.
write_flow(io : IO, channel : UInt16, next_incoming_id : UInt32, incoming_window : UInt32, next_outgoing_id : UInt32, outgoing_window : UInt32, handle : UInt32 | Nil = nil, delivery_count : UInt32 | Nil = nil, link_credit : UInt32 | Nil = nil, drain : Bool = false) : UInt64
Sourcewrite_transfer_performative(io, handle, delivery_id, delivery_tag, more, settled) : Nil
Source