blob: 40f7e547d79ca067848b6e51f504cef50a3dcf79 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
onrtctransform = (event) => {
const transformer = event.transformer;
transformer.reader = transformer.readable.getReader();
transformer.writer = transformer.writable.getWriter();
async function waitForDetachAndPostMetadata(frame) {
while (true) {
if (frame.data.byteLength == 0) {
// frame.data has been detached! Verify metadata is still there.
self.postMessage({
name: `${transformer.options.name} after write`,
timestamp: frame.timestamp, type: frame.type,
metadata: frame.getMetadata()
});
return;
}
await new Promise(r => setTimeout(r, 100));
}
}
let isFirstFrame = true;
function process(transformer)
{
transformer.reader.read().then(chunk => {
if (chunk.done)
return;
if (isFirstFrame) {
isFirstFrame = false;
self.postMessage({
name: transformer.options.name,
timestamp: chunk.value.timestamp,
type: chunk.value.type,
metadata: chunk.value.getMetadata()
});
waitForDetachAndPostMetadata(chunk.value);
}
transformer.writer.write(chunk.value);
process(transformer);
});
}
process(transformer);
};
self.postMessage("registered");
|
