class Faye::WebSocket::HybiParser::StreamReader

def initialize
  @queue = []
end

def put(bytes)
  return unless bytes and bytes.size > 0
  @queue.concat(bytes)
end

def read(length)
  read_bytes(length)
end

def read_bytes(length)
  return nil if length > @queue.size
  @queue.shift(length)
end