Function processChunk

inject.js:428–453

(value, stream)

    };

    const processChunk = (value, stream) => {
      if (!value) return;
      if (!shouldObserveStream(stream)) return;

      buffer += decoder.decode(value, { stream: true });

      if (isSSE) {
        const boundaryIndex = findCompleteSSEBoundary(buffer);
        if (boundaryIndex !== null) {
          const completeData = buffer.substring(0, boundaryIndex);
          buffer = buffer.substring(boundaryIndex);
          const events = parseSSEEvents(completeData);
          for (const event of events) {
            emitMessage(event.event, event.data, event.id);
          }
        }
      } else if (isNDJSON) {
        const lines = buffer.split(/\r?\n/);
        buffer = lines.pop() || '';
        for (const line of lines) {
          if (line.trim()) {
            emitMessage('message', line);
          }
        }
      }
    };

    const createObserverTransform = (stream) => new TransformStream({
      transform(chunk, controller) {