class AMQ::Protocol::Stream

• AMQ::Protocol::Stream
• IO
• Reference
• Object

Overview

An IO wrapper that enforces AMQP frame size limits and reads frames Use #next_frame to read the next frame from the stream Don't use #read directly unless you know what you're doing

Defined in:

Constructors

• .new(io : IO, frame_max : UInt32 = 8192_u32, format : IO::ByteFormat = IO::ByteFormat::NetworkEndian)

  Construct a new Stream wrapping the given io frame_max applies to payload size only, excluding the 8-byte frame envelope (7-byte header + 1-byte end marker)

Instance Method Summary

• #flush

  Flushes buffered data, if any.

• #next_frame(& : Frame -> _)
• #next_frame : Frame
• #read(slice : Bytes)

  Reads at most slice.size bytes from this IO into slice.

• #write(slice : Bytes) : Nil

  Delegate write to underlying IO without frame size checks

Constructor Detail

Instance Method Detail

io = IO::Memory.new "hello"
slice = Bytes.new(4)
io.read(slice) # => 4
slice          # => Bytes[104, 101, 108, 108]
io.read(slice) # => 1
slice          # => Bytes[111, 101, 108, 108]
io.read(slice) # => 0