Class: StompOut::Parser

Inherits:
Object
  • Object
show all
Defined in:
lib/stomp_out/parser.rb

Overview

Parser for converting stream of data from connection into STOMP frames

Instance Method Summary collapse

Constructor Details

#initializeParser

Create frame parser



31
32
33
34
35
36
# File 'lib/stomp_out/parser.rb', line 31

def initialize
  @buffer = ""
  @body_length = nil
  @frame = Frame.new
  @frames = []
end

Instance Method Details

#<<(buf) ⇒ TrueClass

Add data received from connection to end of buffer

Returns:

  • (TrueClass)

    always true



41
42
43
44
# File 'lib/stomp_out/parser.rb', line 41

def <<(buf)
  @buffer << buf
  parse
end

#nextFrame, NilClass

Get next frame

Returns:

  • (Frame, NilClass)

    frame or nil if none available



49
50
51
# File 'lib/stomp_out/parser.rb', line 49

def next
  @frames.shift
end