Module: Plum::FrameUtils

Included in:
Frame
Defined in:
lib/plum/frame_utils.rb

Instance Method Summary collapse

Instance Method Details

#parse_settings ⇒ Hash<Symbol, Integer>

Parses SETTINGS frame payload. Ignores unknown settings type (see RFC7540 6.5.2).

Returns:

  • (Hash<Symbol, Integer>) —

    The parsed strings.



32
33
34
35
36
37
38
39
40
41
 
# File 'lib/plum/frame_utils.rb', line 32

def parse_settings
  settings = {}
  payload.each_byteslice(6) do |param|
    id = param.uint16
    name = Frame::SETTINGS_TYPE.key(id)
    # ignore unknown settings type
    settings[name] = param.uint32(2) if name
  end
  settings
end

#split(max) {|Frame| ... } ⇒ Object

Splits this frame into multiple frames not to exceed MAX_FRAME_SIZE.

Parameters:

  • max (Integer) —

    The maximum size of a frame payload.

Yields:

  • (Frame) —

    The splitted frames.



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/plum/frame_utils.rb', line 9

def split(max)
  return yield self if @length <= max
  first, *mid, last = @payload.chunk(max)
  case type
  when :data
    yield Frame.new(type_value: 0, stream_id: @stream_id, payload: first, flags_value: @flags_value & ~1)
    mid.each { |slice|
      yield Frame.new(type_value: 0, stream_id: @stream_id, payload: slice, flags_value: 0)
    }
    yield Frame.new(type_value: 0, stream_id: @stream_id, payload: last, flags_value: @flags_value & 1)
  when :headers, :push_promise
    yield Frame.new(type_value: @type_value, stream_id: @stream_id, payload: first, flags_value: @flags_value & ~4)
    mid.each { |slice|
      yield Frame.new(type: :continuation, stream_id: @stream_id, payload: slice, flags_value: 0)
    }
    yield Frame.new(type: :continuation, stream_id: @stream_id, payload: last, flags_value: @flags_value & 4)
  else
    raise NotImplementedError.new("frame split of frame with type #{type} is not supported")
  end
end