public function stream(): void
{
    @set_time_limit(120);
    @ini_set('output_buffering', 'off');

    // ① SSE 필수 헤더
    header('Content-Type: text/event-stream; charset=UTF-8');
    header('Cache-Control: no-cache');
    header('X-Accel-Buffering: no');    // nginx 버퍼링 비활성화

    if (ob_get_level()) ob_end_flush();

    $lastId = (int)($_SERVER['HTTP_LAST_EVENT_ID'] ?? 0);
    $db     = \Config\Database::connect();

    for ($tick = 0; $tick < 30; $tick++) {
        if (connection_aborted()) break;

        $id = $lastId + $tick + 1;

        // ② 이벤트 전송 형식
        // id: {고유 ID}
        // event: {이벤트 타입}
        // data: {JSON 문자열}
        // (빈 줄 2개로 이벤트 종료)
        echo "id: {$id}\n";
        echo "event: system\n";
        echo 'data: ' . json_encode([
            'time'   => date('H:i:s'),
            'memory' => round(memory_get_usage(true) / 1024 / 1024, 1),
        ]) . "\n\n";

        flush();   // ③ 즉시 전송
        sleep(2);  // ④ 2초 대기 후 다음 이벤트
    }

    // ⑤ 재연결 유도 (max ticks 후 연결 종료)
    echo "event: reconnect\ndata: {}\n\n";
    flush();
}

// ① EventSource 생성
const es = new EventSource('/examples/sse/stream');

// ② 기본 message 이벤트
es.onmessage = (e) => {
    const data = JSON.parse(e.data);
    console.log('message:', data);
};

// ③ 커스텀 이벤트 타입 수신
es.addEventListener('system', (e) => {
    const data = JSON.parse(e.data);
    document.getElementById('sysTime').textContent = data.time;
});

es.addEventListener('queue', (e) => {
    const data = JSON.parse(e.data);
    document.getElementById('qPending').textContent = data.pending;
});

es.addEventListener('notify', (e) => {
    const data = JSON.parse(e.data);
    showNotification(data.message);
});

// ④ 재연결 이벤트 (서버가 연결을 끊으면 자동 재연결)
es.addEventListener('reconnect', () => {
    es.close();
    setTimeout(() => reconnect(), 1000);
});

// ⑤ 에러 처리 (자동 재연결 내장)
es.onerror = (e) => {
    console.warn('SSE 오류 — 자동 재연결 시도 중...');
};

// ⑥ 연결 종료
function stopSSE() {
    es.close();
}