Module: GRPCWeb::MessageFraming

Defined in:
lib/grpc_web/message_framing.rb

Overview

Placeholder

Class Method Summary collapse

Class Method Details

.pack_frames(frames) ⇒ Object 



8
9
10
11
12
13
 
# File 'lib/grpc_web/message_framing.rb', line 8

def pack_frames(frames)
  frames.map do |frame|
    length_bytes = [frame.body.bytesize].pack('N')
    "#{frame.frame_type.chr}#{length_bytes}#{frame.body}"
  end.join
end

.unpack_frames(content) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/grpc_web/message_framing.rb', line 15

def unpack_frames(content)
  frames = []
  remaining_content = content
  until remaining_content.empty?
    msg_length = remaining_content[1..4].unpack1('N')
    raise 'Invalid message length' if msg_length <= 0

    frame_end = 5 + msg_length
    frames << ::GRPCWeb::MessageFrame.new(
      remaining_content[0].bytes[0],
      remaining_content[5...frame_end],
    )
    remaining_content = remaining_content[frame_end..-1]
  end
  frames
end