AMQP10::Protocol::FrameReader
Inherits Reference < Object
Constructors
new(io : IO, max_frame_size : UInt32)
The read buffer is allocated once, sized for max_frame_size (at least
MIN_MAX_FRAME_SIZE), and reused for every frame.
Instance methods
buffer_size
The largest frame the buffer can hold; max_frame_size can be lowered to at most this.
max_frame_size=(size : UInt32) : Nil
Lowers the accepted frame size to the negotiated one without reallocating the buffer, so the reader used for the Open handshake can carry on serving the connection.
read
Resumable: when the IO raises partway through a frame, calling read again continues that frame with the bytes already read.