Method: ASIR::Transport::PayloadIO#_read

Defined in:
lib/asir/transport/payload_io.rb

#_read(stream, state) ⇒ Object 



28
29
30
31
32
33
34
 
# File 'lib/asir/transport/payload_io.rb', line 28

def _read stream, state
  size = /\d+$/.match(stream.readline.chomp)[0].to_i # HEADER (size)
  payload = stream.read(size)
  stream.readline # FOOTER
  stream.readline
  payload
end