# File lib/amq/protocol/client.rb, line 249 def self.encode_body(body, channel, frame_size) return [] if body.empty? # See https://dev.rabbitmq.com/wiki/Amqp091Errata#section_11 limit = frame_size - 8 array = Array.new while body payload, body = body[0, limit], body[limit, body.length - limit] # array << [0x03, payload] array << BodyFrame.new(payload, channel) end array end