Cant stream MJPEG with multipart/x-mixed-replace about pistache HOT 2 OPEN

import io
import random
from flask import Flask, Response
from flask import make_response
from PIL import Image
import time

app = Flask(__name__)

@app.route('/stream')
def stream():
    def generate_noise_image():
        while True:
            # Generate a random noise image
            img = Image.frombytes('RGB', (640, 480), bytes(random.getrandbits(8) for _ in range(640 * 480 * 3)))

            # Convert the image to JPEG format
            img_io = io.BytesIO()
            img.save(img_io, 'JPEG')
            img_io.seek(0)
            # Yield the image data
            yield (b'--frame\r\n'
                   b'Content-Type: image/jpeg\r\n\r\n' + img_io.getvalue() + b'\r\n')
            
            #pause script execution for half a second
            time.sleep(0.5)

    return Response(generate_noise_image(), mimetype='multipart/x-mixed-replace; boundary=frame')

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=8013, debug=True)

 curl -v 127.0.0.1:8013/stream
*   Trying 127.0.0.1:8013...
* Connected to 127.0.0.1 (127.0.0.1) port 8013 (#0)
> GET /stream HTTP/1.1
> Host: 127.0.0.1:8013
> User-Agent: curl/7.81.0
> Accept: */*
> 
* Mark bundle as not supporting multiuse
< HTTP/1.1 200 OK
< Server: Werkzeug/2.2.2 Python/3.10.12
< Date: Sat, 27 Apr 2024 04:44:57 GMT
< Content-Type: multipart/x-mixed-replace; boundary=frame
< Transfer-Encoding: chunked
< Connection: close
< 
Warning: Binary output can mess up your terminal. Use "--output -" to tell 
Warning: curl to output it to your terminal anyway, or consider "--output 
Warning: <FILE>" to save to a file.
* Failure writing output to destination
* Failed reading the chunked-encoded stream
* Closing connection 0

curl --output - -v 127.0.0.1:8013/stream
*   Trying 127.0.0.1:8013...
* Connected to 127.0.0.1 (127.0.0.1) port 8013 (#0)
> GET /stream HTTP/1.1
> Host: 127.0.0.1:8013
> User-Agent: curl/7.81.0
> Accept: */*
> 
* Mark bundle as not supporting multiuse
< HTTP/1.1 200 OK
< Server: Werkzeug/2.2.2 Python/3.10.12
< Date: Fri, 26 Apr 2024 14:38:44 GMT
< Content-Type: multipart/x-mixed-replace; boundary=frame
< Transfer-Encoding: chunked
< Connection: close
< 
--frame
Content-Type: image/jpeg

happy string
--frame
Content-Type: image/jpeg

happy string
--frame
Content-Type: image/jpeg

happy string
--frame
Content-Type: image/jpeg

void VideoStreamer::streamVideoFramesChunked(const Pistache::Rest::Request& request, Pistache::Http::ResponseWriter response)
{
    response.headers()
        .add<Pistache::Http::Header::Server>("pistache/0.1")
        .add<Pistache::Http::Header::Connection>(Pistache::Http::ConnectionControl::KeepAlive)
        .add<Pistache::Http::Header::ContentType>("multipart/x-mixed-replace; boundary=frame");

    auto stream = response.stream(Pistache::Http::Code::Ok);

    auto cameraId = request.param(":cameraId").as<std::string>();
    const int camSearchTimeout = 20000; // ms
    int time_passed = 0; // ms
    const int frameRetrievalInterval = 500; //ms
    uint64_t lastFrameTimestamp = UINT64_MAX;


    try {
        while (true) 
        {
            std::vector<unsigned char> frameBuffer;
            {
                std::lock_guard<std::mutex> lock(frameMutex);
                auto it = frameMap.find(cameraId);
                if (it != frameMap.end() && it->second.second != lastFrameTimestamp) {
                    cv::imencode(".jpg", it->second.first, frameBuffer);
                    frameBuffer.size() > 0 ? time_passed = 0 : time_passed += frameRetrievalInterval;
                    lastFrameTimestamp = it->second.second;
                }
                else {
                    time_passed += frameRetrievalInterval;
                    if ((time_passed % 5000) == 0) UMOJO_LOG("Pistache: Waiting for cam {}/{} ...", cameraId, time_passed / 1000);
                }
            }

            if (frameBuffer.size() > 0) {
                std::string frameBufferStr(frameBuffer.begin(), frameBuffer.end());
                LOG("Pistache: Sending frame for camera {}, buffer length: {}", cameraId, frameBufferStr.size());
                stream << "--frame\r\nContent-Type: image/jpeg\r\n\r\n";
                stream << frameBufferStr.c_str();
                stream << "\r\n";
                stream << Pistache::Http::flush;
            }

            if (time_passed >= camSearchTimeout) {
                LOG("Pistache: Camera {} not found, exiting by timeout", cameraId);
                break;
            }

            std::this_thread::sleep_for(std::chrono::milliseconds(frameRetrievalInterval));
        }
    }
    catch (const std::exception& e) {
        // Handle exceptions if needed
        LOG("Pistache exception: {}", e.what());
    }
}

curl --output - -v 127.0.0.1:8013/stream
*   Trying 127.0.0.1:8013...
* Connected to 127.0.0.1 (127.0.0.1) port 8013 (#0)
> GET /stream/arlington_SCR2326W_media-inference-arlingtons-k8s_dev HTTP/1.1
> Host: 127.0.0.1:8013
> User-Agent: curl/7.81.0
> Accept: */*
> 
* Mark bundle as not supporting multiuse
< HTTP/1.1 200 OK
< Content-Type: multipart/x-mixed-replace; boundary=frame
< Server: pistache/0.1
< Connection: Close
< Transfer-Encoding: chunked
< 
--frame
Content-Type: image/jpeg

����
--frame
Content-Type: image/jpeg

����
--frame
Content-Type: image/jpeg

����
--frame
Content-Type: image/jpeg