chromium/src/third_party/blink/web_tests/external/wpt/native-io/concurrent_io/concurrent_io_write_async.tentative.https.any.js

// META: title=NativeIO API: Concurrent IO while write is resolving.
// META: global=window,worker
// META: script=operation_helpers.js
// META: script=../resources/support.js
// META: timeout=long

'use strict';

// See documentation in operation_helpers.js

for (let op of kOperations) {
  promise_test(async testCase => {
    await reserveAndCleanupCapacity(testCase);

    const file = await createFile(testCase, 'write_file');

    const res = op.prepare();

    const writePromise = file.write(new Uint8Array([96, 97, 98, 99]), 0);
    await op.assertRejection(testCase, file, res);

    const {buffer: writeBuffer, writtenBytes} = await writePromise;
    assert_equals(writtenBytes, 4);

    const {buffer: readBuffer, readBytes} =
      await file.read(new Uint8Array(4), 0);

    assert_equals(readBytes, 4,
                  `NativeIOFile.read() should not fail after a rejected ` +
                    `${op.name} during write()`);
    assert_array_equals(readBuffer, writeBuffer,
                        `Rejecting ${op.name} during write() should still ` +
                          `complete the write.`);
    op.assertUnchanged(res);
  }, `${op.name}() rejects while write() is resolving.`);
};