servo/tests/wpt/web-platform-tests/fetch/api/request/request-init-stream.any.js

// META: global=window,worker

"use strict";

test(() => {
  const stream = new ReadableStream();
  const request = new Request("...", { method:"POST", body: stream });
  assert_equals(request.body, stream);
}, "Constructing a Request with a stream holds the original object.");

async function assert_request(test, input, init) {
  assert_throws_js(TypeError, () => new Request(input, init), "new Request()");
  await promise_rejects_js(test, TypeError, fetch(input, init), "fetch()");
}

promise_test(async (t) => {
  const stream = new ReadableStream();
  stream.getReader();
  await assert_request(t, "...", { method:"POST", body: stream });
}, "Constructing a Request with a stream on which getReader() is called");

promise_test(async (t) => {
  const stream = new ReadableStream();
  stream.getReader().read();
  await assert_request(t, "...", { method:"POST", body: stream });
}, "Constructing a Request with a stream on which read() is called");

promise_test(async (t) => {
  const stream = new ReadableStream({ pull: c => c.enqueue(new Uint8Array()) }),
        reader = stream.getReader();
  await reader.read();
  reader.releaseLock();
  await assert_request(t, "...", { method:"POST", body: stream });
}, "Constructing a Request with a stream on which read() and releaseLock() are called");

promise_test(async (t) => {
  const request = new Request("...", { method: "POST", body: "..." });
  request.body.getReader();
  await assert_request(t, request);
  assert_class_string(new Request(request, { body: "..." }), "Request");
}, "Constructing a Request with a Request on which body.getReader() is called");

promise_test(async (t) => {
  const request = new Request("...", { method: "POST", body: "..." });
  request.body.getReader().read();
  await assert_request(t, request);
  assert_class_string(new Request(request, { body: "..." }), "Request");
}, "Constructing a Request with a Request on which body.getReader().read() is called");

promise_test(async (t) => {
  const request = new Request("...", { method: "POST", body: "..." }),
        reader = request.body.getReader();
  await reader.read();
  reader.releaseLock();
  await assert_request(t, request);
  assert_class_string(new Request(request, { body: "..." }), "Request");
}, "Constructing a Request with a Request on which read() and releaseLock() are called");