Sha256: b3861b2831857f5096c0b509ae9cda89c11f4127f58dce2bb54b607eef75afd9
Contents?: true
Size: 1.17 KB
Versions: 5
Compression:
Stored size: 1.17 KB
Contents
# frozen_string_literal: true
# Released under the MIT License.
# Copyright, 2019-2024, by Samuel Williams.
require "protocol/http/body/readable"
module Protocol
module HTTP1
module Body
# A body that reads all remaining data from the connection.
class Remainder < HTTP::Body::Readable
BLOCK_SIZE = 1024 * 64
# block_size may be removed in the future. It is better managed by connection.
def initialize(connection)
@connection = connection
end
def empty?
@connection.nil?
end
def discard
if connection = @connection
@connection = nil
# Ensure no further requests can be read from the connection, as we are discarding the body which may not be fully read:
connection.close_read
end
end
def close(error = nil)
self.discard
super
end
def read
@connection&.readpartial(BLOCK_SIZE)
rescue EOFError
if connection = @connection
@connection = nil
connection.receive_end_stream!
end
return nil
end
def inspect
"\#<#{self.class} state=#{@connection ? 'open' : 'closed'}>"
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems