class WebSocket::Driver::Hybi

def emit_message
  message  = @extensions.process_incoming_message(@message)
  @message = nil
  payload = message.data
  case message.opcode
    when OPCODES[:text] then
      payload = Driver.encode(payload, Encoding::UTF_8)
      payload = nil unless payload.valid_encoding?
    when OPCODES[:binary]
      if @binary_data_format == :array
        payload = payload.bytes.to_a
      else
        payload = Driver.encode(payload, Encoding::BINARY)
      end
  end
  if payload
    emit(:message, MessageEvent.new(payload))
  else
    fail(:encoding_error, 'Could not decode a text frame as UTF-8')
  end
rescue ::WebSocket::Extensions::ExtensionError => error
  fail(:extension_error, error.message)
end