class WebSocket::Driver::Hybi

def initialize(socket, options = {}) 

def initialize(socket, options = {})
  super
  reset
  @reader          = StreamReader.new
  @stage           = 0
  @masking         = options[:masking]
  @protocols       = options[:protocols] || []
  @protocols       = @protocols.strip.split(/\s*,\s*/) if String === @protocols
  @require_masking = options[:require_masking]
  @ping_callbacks  = {}
  return unless @socket.respond_to?(:env)
  if protos = @socket.env['HTTP_SEC_WEBSOCKET_PROTOCOL']
    protos = protos.split(/\s*,\s*/) if String === protos
    @protocol = protos.find { |p| @protocols.include?(p) }
  end
end