chromium/src/third_party/blink/web_tests/external/wpt/webtransport/quic/client-indication.sub.any.js

// META: quic=true
// META: script=/common/get-host-info.sub.js

const PORT = '{{ports[quic-transport][0]}}';
const {ORIGINAL_HOST: HOST, ORIGIN} = get_host_info();
const BASE = `quic-transport://${HOST}:${PORT}`;

promise_test(async (test) => {
  function onClosed() {
    assert_unreached('The closed promise should be ' +
                     'fulfilled or rejected after getting a PASS signal.');
  }
  const qt = new QuicTransport(
    `${BASE}/client-indication.quic.py?origin=${ORIGIN}`);
  qt.closed.then(test.step_func(onClosed), test.step_func(onClosed));

  const streams = qt.receiveStreams();
  const {done, value} = await streams.getReader().read();
  assert_false(done, 'getting an incoming stream');

  const readable = value.readable.pipeThrough(new TextDecoderStream());
  const reader = readable.getReader();
  let result = '';
  while (true) {
    const {done, value} = await reader.read();
    if (done) {
        break;
    }
    result += value;
  }
  assert_equals(result, 'PASS');
}, 'Client indication');