test: retry test for delayed messages

Author: chrisguttandin

test/expectation/safari/current/audio-worklet-node.js

@@ -19,33 +19,41 @@ describe('AudioWorklet', () => {
     });
 
     describe('with a processor which transfers the arguments', () => {
-        let audioWorkletNode;
-
-        beforeEach(async () => {
-            await offlineAudioContext.audioWorklet.addModule('test/fixtures/transferring-processor.js');
+        // bug #197
 
-            audioWorkletNode = new AudioWorkletNode(offlineAudioContext, 'transferring-processor');
-        });
+        it('should not deliver the messages before the promise returned by startRendering() resolves', async () => {
+            while (true) {
+                await offlineAudioContext.audioWorklet.addModule('test/fixtures/transferring-processor.js');
 
-        // bug #197
+                const audioWorkletNode = new AudioWorkletNode(offlineAudioContext, 'transferring-processor');
+                const onmessage = spy();
 
-        it('should not deliver the messages before the promise returned by startRendering() resolves', () => {
-            const { promise, resolve } = Promise.withResolvers();
-            const onmessage = spy();
+                audioWorkletNode.port.onmessage = onmessage;
 
-            audioWorkletNode.port.onmessage = onmessage;
+                try {
+                    await offlineAudioContext.startRendering().then(() => {
+                        expect(onmessage).to.have.not.been.called;
 
-            offlineAudioContext.startRendering().then(() => {
-                expect(onmessage).to.have.not.been.called;
+                        return new Promise((resolve, reject) => {
+                            setTimeout(() => {
+                                try {
+                                    expect(onmessage).to.have.been.calledTwice;
 
-                setTimeout(() => {
-                    expect(onmessage).to.have.been.calledTwice;
+                                    resolve();
+                                } catch (err) {
+                                    reject(err);
+                                }
+                            });
+                        });
+                    });
+                } catch (err) {
+                    offlineAudioContext = new OfflineAudioContext(1, offlineAudioContext.length, offlineAudioContext.sampleRate);
 
-                    resolve();
-                });
-            });
+                    continue;
+                }
 
-            return promise;
+                break;
+            }
         });
     });
 });

test/expectation/safari/penultimate/audio-worklet-node.js

@@ -19,33 +19,41 @@ describe('AudioWorklet', () => {
     });
 
     describe('with a processor which transfers the arguments', () => {
-        let audioWorkletNode;
-
-        beforeEach(async () => {
-            await offlineAudioContext.audioWorklet.addModule('test/fixtures/transferring-processor.js');
+        // bug #197
 
-            audioWorkletNode = new AudioWorkletNode(offlineAudioContext, 'transferring-processor');
-        });
+        it('should not deliver the messages before the promise returned by startRendering() resolves', async () => {
+            while (true) {
+                await offlineAudioContext.audioWorklet.addModule('test/fixtures/transferring-processor.js');
 
-        // bug #197
+                const audioWorkletNode = new AudioWorkletNode(offlineAudioContext, 'transferring-processor');
+                const onmessage = spy();
 
-        it('should not deliver the messages before the promise returned by startRendering() resolves', () => {
-            const { promise, resolve } = Promise.withResolvers();
-            const onmessage = spy();
+                audioWorkletNode.port.onmessage = onmessage;
 
-            audioWorkletNode.port.onmessage = onmessage;
+                try {
+                    await offlineAudioContext.startRendering().then(() => {
+                        expect(onmessage).to.have.not.been.called;
 
-            offlineAudioContext.startRendering().then(() => {
-                expect(onmessage).to.have.not.been.called;
+                        return new Promise((resolve, reject) => {
+                            setTimeout(() => {
+                                try {
+                                    expect(onmessage).to.have.been.calledTwice;
 
-                setTimeout(() => {
-                    expect(onmessage).to.have.been.calledTwice;
+                                    resolve();
+                                } catch (err) {
+                                    reject(err);
+                                }
+                            });
+                        });
+                    });
+                } catch (err) {
+                    offlineAudioContext = new OfflineAudioContext(1, offlineAudioContext.length, offlineAudioContext.sampleRate);
 
-                    resolve();
-                });
-            });
+                    continue;
+                }
 
-            return promise;
+                break;
+            }
         });
     });
 });

test/expectation/safari/previous/audio-worklet-node.js

@@ -19,33 +19,41 @@ describe('AudioWorklet', () => {
     });
 
     describe('with a processor which transfers the arguments', () => {
-        let audioWorkletNode;
-
-        beforeEach(async () => {
-            await offlineAudioContext.audioWorklet.addModule('test/fixtures/transferring-processor.js');
+        // bug #197
 
-            audioWorkletNode = new AudioWorkletNode(offlineAudioContext, 'transferring-processor');
-        });
+        it('should not deliver the messages before the promise returned by startRendering() resolves', async () => {
+            while (true) {
+                await offlineAudioContext.audioWorklet.addModule('test/fixtures/transferring-processor.js');
 
-        // bug #197
+                const audioWorkletNode = new AudioWorkletNode(offlineAudioContext, 'transferring-processor');
+                const onmessage = spy();
 
-        it('should not deliver the messages before the promise returned by startRendering() resolves', () => {
-            const { promise, resolve } = Promise.withResolvers();
-            const onmessage = spy();
+                audioWorkletNode.port.onmessage = onmessage;
 
-            audioWorkletNode.port.onmessage = onmessage;
+                try {
+                    await offlineAudioContext.startRendering().then(() => {
+                        expect(onmessage).to.have.not.been.called;
 
-            offlineAudioContext.startRendering().then(() => {
-                expect(onmessage).to.have.not.been.called;
+                        return new Promise((resolve, reject) => {
+                            setTimeout(() => {
+                                try {
+                                    expect(onmessage).to.have.been.calledTwice;
 
-                setTimeout(() => {
-                    expect(onmessage).to.have.been.calledTwice;
+                                    resolve();
+                                } catch (err) {
+                                    reject(err);
+                                }
+                            });
+                        });
+                    });
+                } catch (err) {
+                    offlineAudioContext = new OfflineAudioContext(1, offlineAudioContext.length, offlineAudioContext.sampleRate);
 
-                    resolve();
-                });
-            });
+                    continue;
+                }
 
-            return promise;
+                break;
+            }
         });
     });
 });