RTCPeerConnection-worker-transform.js (581B)
1 onmessage = async (event) => { 2 const readableStream = event.data.readableStream; 3 const writableStream = event.data.writableStream; 4 const insertError = event.data.insertError; 5 6 try { 7 await readableStream.pipeThrough(new TransformStream({ 8 transform: (chunk, controller) => { 9 if (insertError) { 10 controller.enqueue("This is not a valid frame"); 11 } else { 12 controller.enqueue(chunk); 13 } 14 } 15 })).pipeTo(writableStream); 16 17 postMessage({success:true}); 18 } catch(e) { 19 postMessage({success:false, error: e}); 20 } 21 22 }