Module: Protocol::HTTP2::Continued
- Included in:
- ContinuationFrame, HeadersFrame, PushPromiseFrame
- Defined in:
- lib/protocol/http2/continuation_frame.rb
Instance Attribute Summary collapse
-
#continuation ⇒ Object
Returns the value of attribute continuation.
Instance Method Summary collapse
- #end_headers? ⇒ Boolean
- #initialize ⇒ Object
- #pack(data, **options) ⇒ Object
- #read(stream, maximum_frame_size) ⇒ Object
- #unpack ⇒ Object
- #write(stream) ⇒ Object
Instance Attribute Details
#continuation ⇒ Object
Returns the value of attribute continuation.
66 67 68 |
# File 'lib/protocol/http2/continuation_frame.rb', line 66 def continuation @continuation end |
Instance Method Details
#end_headers? ⇒ Boolean
32 33 34 |
# File 'lib/protocol/http2/continuation_frame.rb', line 32 def end_headers? flag_set?(END_HEADERS) end |
#initialize ⇒ Object
26 27 28 29 30 |
# File 'lib/protocol/http2/continuation_frame.rb', line 26 def initialize(*) super @continuation = nil end |
#pack(data, **options) ⇒ Object
68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 |
# File 'lib/protocol/http2/continuation_frame.rb', line 68 def pack(data, **) maximum_size = [:maximum_size] if maximum_size and data.bytesize > maximum_size clear_flags(END_HEADERS) super(data.byteslice(0, maximum_size), **) remainder = data.byteslice(maximum_size, data.bytesize-maximum_size) @continuation = ContinuationFrame.new @continuation.pack(remainder, maximum_size: maximum_size) else set_flags(END_HEADERS) super data, ** @continuation = nil end end |
#read(stream, maximum_frame_size) ⇒ Object
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/protocol/http2/continuation_frame.rb', line 36 def read(stream, maximum_frame_size) super unless end_headers? continuation = ContinuationFrame.new continuation.read_header(stream) # We validate the frame type here: unless continuation.valid_type? raise ProtocolError, "Invalid frame type: #{@type}!" end if continuation.stream_id != @stream_id raise ProtocolError, "Invalid stream id: #{continuation.stream_id} for continuation of stream id: #{@stream_id}!" end continuation.read(stream, maximum_frame_size) @continuation = continuation end end |
#unpack ⇒ Object
89 90 91 92 93 94 95 |
# File 'lib/protocol/http2/continuation_frame.rb', line 89 def unpack if @continuation.nil? super else super + @continuation.unpack end end |
#write(stream) ⇒ Object
58 59 60 61 62 63 64 |
# File 'lib/protocol/http2/continuation_frame.rb', line 58 def write(stream) super if continuation = self.continuation continuation.write(stream) end end |