Method closeConnection

Libraries/Http/HttpAsyncClient.cpp:900–930

    currentRequest = nullptr;

    if (shouldFinishBodyStream)
    {
        response.finishBodyStream();
    }

    if (not keepAlive and state == State::Idle and currentRequest == nullptr)
    {
        closeConnection();
    }
}

void HttpAsyncClient::closeConnection()
{
    if (connection == nullptr)
    {
        return;
    }
    (void)connection->getReadableTransportStream()
        .eventData.removeListener<HttpAsyncClient, &HttpAsyncClient::onResponseData>(*this);
    (void)connection->getReadableTransportStream()
        .eventData.removeListener<HttpAsyncClient, &HttpAsyncClient::onResponseBodyData>(*this);
    (void)connection->getReadableTransportStream()
        .eventError.removeListener<HttpAsyncClient, &HttpAsyncClient::onReadableError>(*this);
    (void)connection->getWritableTransportStream()
        .eventError.removeListener<HttpAsyncClient, &HttpAsyncClient::onWritableError>(*this);
    (void)connection->getReadableTransportStream()
        .eventEnd.removeListener<HttpAsyncClient, &HttpAsyncClient::onReadableEnd>(*this);
    (void)connection->pipeline.eventError.removeListener<HttpAsyncClient, &HttpAsyncClient::onPipelineError>(*this);
    (void)connection->pipeline.unpipe();
    if (transportClose.isValid())
    {
        transportClose();
    }
    connection->readableSocketStream.destroy();