# File lib/websocket/driver/hybi/stream_reader.rb, line 6 def initialize @queue = [] end
# File lib/websocket/driver/hybi/stream_reader.rb, line 14 def put(bytes) return unless bytes and bytes.size > 0 @queue.concat(bytes) end
# File lib/websocket/driver/hybi/stream_reader.rb, line 10 def read(length) read_bytes(length) end
# File lib/websocket/driver/hybi/stream_reader.rb, line 21 def read_bytes(length) return nil if length > @queue.size @queue.shift(length) end