Missing Final Multipart of boundary

[Jimmycheakc]

bool Camera::do_subscribeToSnapShot(Poco::Net::HTTPClientSession& session, Poco::Net::HTTPRequest& request, Poco::Net::HTTPResponse& response)
{
session.sendRequest(request);
std::istream& rs = session.receiveResponse(response);

// Log the response header
std::ostringstream msg;
msg << "Status : " << response.getStatus() << " Reason : " << response.getReason();
AppLogger::getInstance()->FnLog(msg.str());

if (response.getStatus() != Poco::Net::HTTPResponse::HTTP_UNAUTHORIZED)
{
    std::string contentType = response.get("Content-Type", "");
    std::string boundary;
    Poco::Net::NameValueCollection params;

    Poco::Net::MessageHeader::splitParameters(contentType.begin(), contentType.end(), params);
    boundary = params.get("boundary", "");
    Poco::Net::MultipartReader reader(rs, boundary);
    event_t event;
    memset(&event, 0 , sizeof(event));

    while (reader.hasNextPart())
    {
        Poco::Net::MessageHeader partHeader;
        reader.nextPart(partHeader);

        std::string ct = partHeader.get("Content-Type", "");
        std::string cl = partHeader.get("Content-Length", "");

        if (!cl.empty() && !ct.empty())
        {
            Poco::Int64 contentLength = std::stoi(cl);
            if (ct == "image/jpeg")
            {
                try
                {
                    AppLogger::getInstance()->FnLog("Saving image.");
                    // Save the image
                    std::string absImagePath;
                    std::string dateTimeImageTime;

                    if (!event.evt_snapshot_time.empty())
                    {
                        try
                        {
                            std::string UTCStr = event.evt_snapshot_time;
                            Poco::trimInPlace(UTCStr);
                            Poco::Int64 intUTC = Poco::NumberParser::parse(UTCStr);
                            Poco::DateTime dateTimeUTC(Poco::Timestamp::fromEpochTime(intUTC));
                            std::string dateTimeUTCStr(Poco::DateTimeFormatter::format(dateTimeUTC, "%y%m%d_%H%M%S"));
                            std::string dateTimeUTCStr2(Poco::DateTimeFormatter::format(dateTimeUTC, "%Y-%m-%d %H:%M:%S"));
                            dateTimeImageTime = dateTimeUTCStr2;
                            absImagePath = imageDirectoryPath + "/Img_" + dateTimeUTCStr + ".jpg";
                        }
                        catch(const Poco::Exception& ex)
                        {
                            std::cerr << "Error Parsing the string as integer : " << ex.displayText() << std::endl;
                        }
                    }
                    else
                    {
                        absImagePath = imageDirectoryPath + "/Img_" + Common::getInstance()->FnFormatDateYYMMDD_HHMMSS() + ".jpg";
                        AppLogger::getInstance()->FnLog("Date for filename is get from current time.");
                    }

                    if (!isImageDirectoryExists())
                    {
                        createImageDirectory();
                    }
                    AppLogger::getInstance()->FnLog("Image stored :" + absImagePath);
                    Poco::FileOutputStream fileStream(absImagePath);
                    Poco::StreamCopier::copyStream(reader.stream(), fileStream, contentLength);
                    fileStream.close();
                }
                catch(Poco::Exception& ex)
                {
                    std::cerr << "Error saving image: " << ex.displayText() << std::endl;
                }
            }
        }
    }

    session.reset();
    return true;
}
else
{
    Poco::NullOutputStream null;
    Poco::StreamCopier::copyStream(rs, null);
    return false;
}

}

Issue Description

Everytime i subscribed successfully, server will keep-alive the connection, send heartbeat every 60s send 3 images, but i only received 2 images and last image will stuck at Poco::StreamCopier::copyStream(reader.stream(), fileStream, contentLength); and last image will received once next heartbeat is received.