class

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.

Source

Instance methods

buffer_size

The largest frame the buffer can hold; max_frame_size can be lowered to at most this.

Source
max_frame_size

Largest frame accepted, header included; never more than the buffer holds.

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

Source
read

Resumable: when the IO raises partway through a frame, calling read again continues that frame with the bytes already read.

Source