77 lines
2.5 KiB
HTML
77 lines
2.5 KiB
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>
|