Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
hybi	[ DIR ]	drwxr-xr-x
client.rb	3.91 KB	-rw-r--r--
draft75.rb	2.39 KB	-rw-r--r--
draft76.rb	2.35 KB	-rw-r--r--
event_emitter.rb	1.14 KB	-rw-r--r--
headers.rb	860 B	-rw-r--r--
hybi.rb	11.94 KB	-rw-r--r--
proxy.rb	1.7 KB	-rw-r--r--
server.rb	1.81 KB	-rw-r--r--
stream_reader.rb	1.09 KB	-rw-r--r--
utf8_match.rb	345 B	-rw-r--r--

Name

Size

Permission

Action

hybi

[ DIR ]

drwxr-xr-x

client.rb

3.91 KB

-rw-r--r--

draft75.rb

2.39 KB

-rw-r--r--

draft76.rb

2.35 KB

-rw-r--r--

event_emitter.rb

1.14 KB

-rw-r--r--

headers.rb

860 B

-rw-r--r--

hybi.rb

11.94 KB

-rw-r--r--

proxy.rb

1.7 KB

-rw-r--r--

server.rb

1.81 KB

-rw-r--r--

stream_reader.rb

1.09 KB

-rw-r--r--

utf8_match.rb

345 B

-rw-r--r--

Code Editor : stream_reader.rb

module WebSocket
  class Driver

class StreamReader
      # Try to minimise the number of reallocations done:
      MINIMUM_AUTOMATIC_PRUNE_OFFSET = 128

def initialize
        @buffer = Driver.encode('', :binary)
        @offset = 0
      end

def put(chunk)
        return unless chunk and chunk.bytesize > 0
        @buffer << Driver.encode(chunk, :binary)
      end

# Read bytes from the data:
      def read(length)
        return nil if (@offset + length) > @buffer.bytesize

chunk = @buffer.byteslice(@offset, length)
        @offset += chunk.bytesize

prune if @offset > MINIMUM_AUTOMATIC_PRUNE_OFFSET

return chunk
      end

def each_byte
        prune

@buffer.each_byte do |octet|
          @offset += 1
          yield octet
        end
      end

private

def prune
        buffer_size = @buffer.bytesize

if @offset > buffer_size
          @buffer = Driver.encode('', :binary)
        else
          @buffer = @buffer.byteslice(@offset, buffer_size - @offset)
        end

@offset = 0
      end
    end

end
end

${this.title}

Code Editor : stream_reader.rb