Function flushBuffer

inject.js:388–406

()

    };

    const flushBuffer = () => {
      if (!buffer.trim()) {
        buffer = '';
        return;
      }

      if (isSSE) {
        const events = parseSSEEvents(buffer + '\n\n');
        for (const event of events) {
          emitMessage(event.event, event.data, event.id);
        }
      } else if (isNDJSON) {
        const lines = buffer.split(/\r?\n/).filter(line => line.trim());
        for (const line of lines) {
          emitMessage('message', line);
        }
      }
      buffer = '';
    };

    const shouldObserveStream = (stream) => {
      if (!activeStream) {