Method processEvtQueue

lib/AsyncHttpClient/src/AsyncHttpClient.cpp:644–683

}

void AsyncHttpClient::processEvtQueue()
{
    Event evt;

    while (true == m_evtQueue.receive(&evt, 0U))
    {
        switch (evt.id)
        {
        case EVENT_ID_CONNECTED:
            onConnect();
            break;

        case EVENT_ID_DISCONNECTED:
            onDisconnect();
            break;

        case EVENT_ID_ERROR:
            onError(evt.u.error);
            break;

        case EVENT_ID_DATA:
            onData(evt.u.data.data, evt.u.data.size);

            if (nullptr != evt.u.data.data)
            {
                m_allocator.deallocateArray(evt.u.data.data);
                evt.u.data.data = nullptr;
                evt.u.data.size = 0U;
            }
            break;

        case EVENT_ID_TIMEOUT:
            onTimeout(evt.u.timeout);
            break;

        default:
            break;
        };
    }
}

void AsyncHttpClient::onConnect()
{