# frozen_string_literal: true # Released under the MIT License. # Copyright, 2019-2023, by Samuel Williams. require_relative 'readable' module Protocol module HTTP module Body # Wrapping body instance. Typically you'd override `#read`. class Wrapper < Readable def self.wrap(message) if body = message.body message.body = self.new(body) end end def initialize(body) @body = body end # The wrapped body. attr :body # Buffer any remaining body. def finish @body.finish end def close(error = nil) @body.close(error) super end def empty? @body.empty? end def ready? @body.ready? end def length @body.length end # Read the next available chunk. def read @body.read end def as_json(...) { class: self.class.name, body: @body&.as_json } end def to_json(...) as_json.to_json(...) end def inspect @body.inspect end def stream? @body.stream? end def call(stream) @body.call(stream) end end end end end