Method onResponseData

Libraries/Http/HttpAsyncClient.cpp:708–820

    if (response.getParser().statusCode == 204 or response.getParser().statusCode == 304)
    {
        return true;
    }
    return response.getParser().statusCode >= 100 and response.getParser().statusCode < 200;
}

bool HttpAsyncClient::responseHasKnownLength() const
{
    StringSpan contentLength;
    return response.getHeader("Content-Length", contentLength);
}

void HttpAsyncClient::onResponseData(AsyncBufferView::ID bufferID)
{
    Span<const char> readData;
    Result           readable = connection->buffersPool.getReadableData(bufferID, readData);
    if (not readable)
    {
        fail(readable);
        return;
    }

    Result parseRes = response.writeHeaders(static_cast<uint32_t>(connection->getHeaderMemory().sizeInBytes()),
                                            readData, connection->getReadableTransportStream(), bufferID);
    if (not parseRes)
    {
        fail(parseRes);
        return;
    }
    if (not response.hasReceivedHeaders())
    {
        return;
    }

    const bool removed = connection->getReadableTransportStream()
                             .eventData.removeListener<HttpAsyncClient, &HttpAsyncClient::onResponseData>(*this);
    (void)(removed);

    if (response.getParser().statusCode < 200 and not responseMustNotHaveBody())
    {
        fail(Result::Error("HttpAsyncClient does not support informational responses"));
        return;
    }

    Result prepareBody(true);
    if (responseMustNotHaveBody())
    {
        response.setBodyBytesRemaining(0);
        response.setBodyFramingKind(HttpBodyFramingKind::None);
        response.setBodyComplete(true);
        prepareBody = response.initBodyStream(connection->buffersPool,
                                              {[this]() -> Result { return onResponseBodyStreamRead(); }});
    }
    else
    {
        prepareBody = response.prepareBodyStream(connection->buffersPool,
                                                 {[this]() -> Result { return onResponseBodyStreamRead(); }}, true);
    }
    if (not prepareBody)