compute_pressure_disconnect_idempotent.https.any.js

Enable keyboard shortcuts

This test has a WPT meta file that expects 1 subtest issues.
This WPT test may be referenced by the following Test IDs:
- /compute-pressure/compute_pressure_disconnect_idempotent.https.any.html - WPT Dashboard Interop Dashboard
- /compute-pressure/compute_pressure_disconnect_idempotent.https.any.sharedworker.html - WPT Dashboard Interop Dashboard
- /compute-pressure/compute_pressure_disconnect_idempotent.https.any.worker.html - WPT Dashboard Interop Dashboard

// META: script=/resources/test-only-api.js

// META: script=resources/pressure-helpers.js

// META: global=window,dedicatedworker,sharedworker

'use strict';

pressure_test(async (t, mockPressureService) => {

  const observer1_changes = [];

  const observer1 = new PressureObserver(changes => {

    observer1_changes.push(changes);

});

  t.add_cleanup(() => observer1.disconnect());

  // Ensure that observer1's schema gets registered before observer2 starts.

  const promise = observer1.observe('cpu');

  observer1.disconnect();

  observer1.disconnect();

  await promise_rejects_dom(t, 'AbortError', promise);

  const observer2_changes = [];

  await new Promise((resolve, reject) => {

    const observer2 = new PressureObserver(changes => {

      observer2_changes.push(changes);

      resolve();

});

    t.add_cleanup(() => observer2.disconnect());

    observer2.observe('cpu').catch(reject);

    mockPressureService.setPressureUpdate('cpu', 'critical');

    mockPressureService.startPlatformCollector(/*sampleInterval=*/ 200);

});

  assert_equals(

      observer1_changes.length, 0,

      'stopped observers should not receive callbacks');

  assert_equals(observer2_changes.length, 1);

  assert_equals(observer2_changes[0][0].state, 'critical');

}, 'Stopped PressureObserver do not receive changes');