diff --git a/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-audio.https.html b/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-audio.https.html index 3d419b2b9a792f..04282d0942cc1f 100644 --- a/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-audio.https.html +++ b/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-audio.https.html @@ -162,56 +162,6 @@ return ontrackPromise; }, 'RTCRtpReceiver.createEncodedStream() throws if not requested in PC configuration'); -promise_test(async t => { - const caller = new RTCPeerConnection({encodedInsertableStreams:true}); - t.add_cleanup(() => caller.close()); - const callee = new RTCPeerConnection(); - t.add_cleanup(() => callee.close()); - - const stream = await navigator.mediaDevices.getUserMedia({audio:true}); - const track = stream.getTracks()[0]; - t.add_cleanup(() => track.stop()); - - const sender = caller.addTrack(track) - const senderStreams = sender.createEncodedStreams(); - - const senderWorker = new Worker('RTCPeerConnection-sender-worker-single-frame.js') - senderWorker.postMessage( - {readableStream: senderStreams.readable}, - [senderStreams.readable]); - - let expectedFrameData = null; - let verifiedFrameData = false; - let numVerifiedFrames = 0; - const onmessagePromise = new Promise(resolve => { - senderWorker.onmessage = t.step_func(message => { - if (!(message.data instanceof RTCEncodedAudioFrame)) { - // This is the first message sent from the Worker to the test. - // It contains an object (not an RTCEncodedAudioFrame) with the same - // fields as the RTCEncodedAudioFrame to be sent in follow-up messages. - // These serve as expected values to validate that the - // RTCEncodedAudioFrame is sent correctly back to the test in the next - // message. - expectedFrameData = message.data; - } else { - // This is the frame sent by the Worker after reading it from the - // readable stream. The Worker sends it twice after sending the - // verification message. - assert_equals(message.data.type, expectedFrameData.type); - assert_equals(message.data.timestamp, expectedFrameData.timestamp); - assert_true(areArrayBuffersEqual(message.data.data, expectedFrameData.data)); - if (++numVerifiedFrames == 2) - resolve(); - } - }); - }); - - exchangeIceCandidates(caller, callee); - await exchangeOfferAnswer(caller, callee); - - return onmessagePromise; -}, 'RTCRtpSender readable stream transferred to a Worker and the Worker sends an RTCEncodedAudioFrame back'); - promise_test(async t => { const caller = new RTCPeerConnection({encodedInsertableStreams:true}); t.add_cleanup(() => caller.close()); diff --git a/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-worker.https.html b/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-worker.https.html index a21a0d90e55cbc..04c9c106b87305 100644 --- a/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-worker.https.html +++ b/webrtc-insertable-streams/RTCPeerConnection-insertable-streams-worker.https.html @@ -9,6 +9,57 @@