Class: Protocol::HTTP1::Body::Chunked
- Inherits:
-
HTTP::Body::Readable
- Object
- HTTP::Body::Readable
- Protocol::HTTP1::Body::Chunked
- Defined in:
- lib/protocol/http1/body/chunked.rb
Constant Summary collapse
- TRAILERS =
'trailers'
- CRLF =
"\r\n"
Instance Method Summary collapse
- #close(error = nil) ⇒ Object
- #empty? ⇒ Boolean
-
#initialize(stream, headers) ⇒ Chunked
constructor
A new instance of Chunked.
- #inspect ⇒ Object
-
#read ⇒ Object
Follows the procedure outlined in tools.ietf.org/html/rfc7230#section-4.1.3.
Constructor Details
#initialize(stream, headers) ⇒ Chunked
Returns a new instance of Chunked.
32 33 34 35 36 37 38 39 40 |
# File 'lib/protocol/http1/body/chunked.rb', line 32 def initialize(stream, headers) @stream = stream @finished = false @headers = headers @length = 0 @count = 0 end |
Instance Method Details
#close(error = nil) ⇒ Object
46 47 48 49 50 51 52 53 54 |
# File 'lib/protocol/http1/body/chunked.rb', line 46 def close(error = nil) # We only close the connection if we haven't completed reading the entire body: unless @finished @stream.close @finished = true end super end |
#empty? ⇒ Boolean
42 43 44 |
# File 'lib/protocol/http1/body/chunked.rb', line 42 def empty? @finished end |
#inspect ⇒ Object
82 83 84 |
# File 'lib/protocol/http1/body/chunked.rb', line 82 def inspect "\#<#{self.class} #{@length} bytes read in #{@count} chunks>" end |
#read ⇒ Object
Follows the procedure outlined in tools.ietf.org/html/rfc7230#section-4.1.3
57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
# File 'lib/protocol/http1/body/chunked.rb', line 57 def read return nil if @finished length = read_line.to_i(16) if length == 0 @finished = true read_trailers return nil end # Read trailing CRLF: chunk = @stream.read(length + 2) # ...and chomp it off: chunk.chomp!(CRLF) @length += length @count += 1 return chunk end |