Function createObserverTransform

inject.js:455–463

(stream)

    };

    const createObserverTransform = (stream) => new TransformStream({
      transform(chunk, controller) {
        processChunk(chunk, stream);
        controller.enqueue(chunk);
      },
      flush() {
        closeConnection(stream);
      }
    });

    return {
      processChunk,