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 @max_length = options[:max_length] || MAX_LENGTH @require_masking = options[:require_masking] @ping_callbacks = {} end