Function flushSubscriber

server/index.js:156–171

(sub)

}

function flushSubscriber(sub) {
    if (sub.draining || sub.closed) return;
    while (sub.queue.length > 0) {
        const chunk = sub.queue[0];
        const ok = sub.res.write(chunk);
        if (!ok) {
            sub.draining = true;
            sub.res.once('drain', () => {
                sub.draining = false;
                flushSubscriber(sub);
            });
            return;
        }
        sub.queue.shift();
    }
}

function setupLogWatcher() {
    if (!fs.existsSync(LOG_DIR)) return;