mediacapture-insertable-streams/MediaStreamTrackProcessor-maxBufferSize.worker.js

// META: title=MediaStreamTrackProcessor maxBufferSize
importScripts("/resources/testharness.js");

function makeVideoFrame(timestamp) {
  const canvas = new OffscreenCanvas(100, 100);
  const ctx = canvas.getContext('2d');
  return new VideoFrame(canvas, {timestamp});
}

promise_test(async t => {
  // The generator will be used as the source for the processor to
  // produce frames in a controlled manner.
  const generator = new VideoTrackGenerator();
  t.add_cleanup(() => generator.track.stop());
  // Use a larger maxBufferSize than the default to ensure no frames
  // will be dropped.
  const processor = new MediaStreamTrackProcessor({track: generator.track, maxBufferSize:10});
  const reader = processor.readable.getReader();
  const writer = generator.writable.getWriter();

  let numReads = 0;
  let resolve = null;
  const promise = new Promise(r => resolve = r);

  const numOperations = 4;
  // Issue reads without waiting for the frames to arrive.
  for (let i = 0; i < numOperations; i++) {
    reader.read().then(dv=> {
      dv.value.close();
      if (++numReads == numOperations)
        resolve();
    });
  }

  // Write video frames in different tasks to "slowly" settle the pending read
  // requests.
  for (let i = 0; i<numOperations; i++) {
     await writer.write(makeVideoFrame(i));
     await new Promise(r=>t.step_timeout(r, 0));
  }

  return promise;

}, "Tests that multiple read requests are eventually settled");

promise_test(async t => {
  // The generator will be used as the source for the processor to
  // produce frames in a controlled manner.
  const generator = new VideoTrackGenerator();
  t.add_cleanup(() => generator.track.stop());
  // Use a larger maxBufferSize than the default to ensure no frames
  // will be dropped.
  const processor = new MediaStreamTrackProcessor({track: generator.track, maxBufferSize:10});
  const reader = processor.readable.getReader();
  const writer = generator.writable.getWriter();

  const numOperations = 4;
  // Write video frames as fast as we can with "slower" reads.
  // requests.
  for (let i = 0; i<numOperations; i++) {
     await writer.write(makeVideoFrame(i));
  }

  let numReads = 0;
  let resolve = null;
  const promise = new Promise(r => resolve = r);

  // Issue reads without waiting for the frames to arrive.
  for (let i = 0; i < numOperations; i++) {
    await new Promise(r=>t.step_timeout(r, 50));
    reader.read().then(dv=> {
      dv.value.close();
      if (++numReads == numOperations)
        resolve();
    });
  }

  return promise;

}, "Tests that multiple write requests are buffered");

done();