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
46
47
48
49
50
|
const modification = 1;
function appendToBuffer(buffer, value) {
const result = new ArrayBuffer(buffer.byteLength + 1);
const byteResult = new Uint8Array(result);
byteResult.set(new Uint8Array(buffer), 0);
byteResult[buffer.byteLength] = value;
return result;
}
function ModifyAndWrite(chunk, transformer) {
chunk.value.data = appendToBuffer(chunk.value.data, modification);
transformer.writer.write(chunk.value);
}
function RestoreAndWrite(chunk, transformer) {
const lastByte = new Uint8Array(chunk.value.data)[chunk.value.data.byteLength - 1];
chunk.value.data = chunk.value.data.slice(0, chunk.value.data.byteLength - 1);
let frameData = chunk.value.data;
transformer.writer.write(chunk.value);
if (lastByte === modification && frameData.byteLength == 0) {
self.postMessage("got expected");
}
else {
self.postMessage("unexpected value: lastByte (got " + lastByte +
", expected " + modification +
"), frame data length (got " + frameData.byteLength +
", expected 0))");
}
}
onrtctransform = (event) => {
const transformer = event.transformer;
transformer.reader = transformer.readable.getReader();
transformer.writer = transformer.writable.getWriter();
async function process(transformer)
{
const chunk = await transformer.reader.read();
if (chunk.done)
return;
if (transformer.options.name === 'sender') // sender
ModifyAndWrite(chunk, transformer);
else // receiver
RestoreAndWrite(chunk, transformer);
await process(transformer);
}
process(transformer);
};
self.postMessage("registered");
|
