Method dispatchEvents

core/network/WebSocket.cpp:270–301

}

void WebSocket::dispatchEvents()
{
    if (_eventQueue.unsafe_empty())
        return;
    if (_delegate)
    {
        auto lck = _eventQueue.get_lock();
        while (!_eventQueue.empty())
        {
            auto event = _eventQueue.front();
            _eventQueue.unsafe_pop_front();

            switch (event->getType())
            {
            case Event::Type::ON_OPEN:
                _delegate->onOpen(this);
                break;
            case Event::Type::ON_CLOSE:
                _delegate->onClose(this, _closeCode, _closeReason);
                break;
            case Event::Type::ON_ERROR:
                _delegate->onError(this, static_cast<ErrorEvent*>(event)->getErrorCode());
                break;
            case Event::Type::ON_MESSAGE:
                _delegate->onMessage(this, WebSocket::Data{static_cast<MessageEvent*>(event)});
                break;
            }

            event->release();
        }
    }
}

void WebSocket::setupParsers()
{