MediaStreamTrackProcessor-with-window-tracks.https.html

<!doctype html>
<html>
<head>
  <title>MediaStreamTrackProcessor</title>
  <link rel="help" href="https://w3c.github.io/mediacapture-insertable-streams">
</head>
<body>
<p class="instructions">When prompted, use the accept button to give permission to use your audio and video devices.</p>
<h1 class="instructions">Description</h1>
<p class="instructions">This test checks that MediaStreamTrackProcessor works as expected on video MediaStreamTracks.</p>
<script src=/resources/testharness.js></script>
<script src=/resources/testharnessreport.js></script>
<script src=/resources/testdriver.js></script>
<script src=/resources/testdriver-vendor.js></script>
<script src='/mediacapture-streams/permission-helper.js'></script>
<script>
async function createWorker(script) {
  script = script + "self.postMessage('ready');";
  const blob = new Blob([script], { type: 'text/javascript' });
  const url = URL.createObjectURL(blob);
  const worker = new Worker(url);
  await new Promise(resolve => worker.onmessage = () => {
      resolve();
  });
  URL.revokeObjectURL(url);
  return worker;
}

promise_test(async t => {
  const stream = await navigator.mediaDevices.getUserMedia({video: true});
  const track = stream.getTracks()[0];
  const worker = await createWorker(`
    let track;
    onmessage = async msg => {
      if (msg.data.type === "stop") {
        track.stop();
        return;
      }
      track = msg.data.track;
      const processor = new MediaStreamTrackProcessor({track});
      const reader = processor.readable.getReader();
      let readResult = await reader.read();
      postMessage(readResult.value);
      readResult.value.close();
      // Continue reading until the stream is done due to a track.stop()
      while (true) {
        readResult = await reader.read();
        if (readResult.done) {
          break;
        } else {
          readResult.value.close();
        }
      }
      await reader.closed;
      postMessage('closed');
    }
  `);

  worker.postMessage({ type: "start", track }, [track]);

  return new Promise(resolve => {
    worker.onmessage = t.step_func(msg => {
      if (msg.data instanceof VideoFrame) {
        msg.data.close();
        worker.postMessage({ type: "stop" });
      } else if (msg.data == 'closed') {
        resolve();
      } else {
        assert_unreached();
      }
    })
  });
}, "Tests that the reader of a video MediaStreamTrackProcessor produces VideoFrame objects and is closed on track stop while running on a worker");

</script>
</body>
</html>
chromium/third_party/blink/web_tests/external/wpt/mediacapture-insertable-streams/MediaStreamTrackProcessor-with-window-tracks.https.html
