// META: global=window,worker
// META: script=/common/get-host-info.sub.js
// META: script=resources/webtransport-test-helpers.sub.js
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// Create a bidirectional stream.
const bidi_stream = await wt.createBidirectionalStream();
// Write a message to the writable end, and close it.
const writer = bidi_stream.writable.getWriter();
const encoder = new TextEncoder();
await writer.write(encoder.encode('Hello World'));
await writer.close();
// Read the data on the readable end.
const reply = await read_stream_as_string(bidi_stream.readable);
// Check that the message from the readable end matches the writable end.
assert_equals(reply, 'Hello World');
}, 'WebTransport client should be able to create and handle a bidirectional stream');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
// Create a bidirectional stream.
const bidi_stream = await wt.createBidirectionalStream();
// Write a message to the writable end, and close it.
const writer = bidi_stream.writable.getWriter();
const encoder = new TextEncoder();
await writer.write(encoder.encode('Hello World'));
await writer.close();
// Read the data on the readable end.
const reply = await read_stream_as_string(bidi_stream.readable);
// Check that the message from the readable end matches the writable end.
assert_equals(reply, 'Hello World');
}, 'WebTransport client should be able to create and handle a bidirectional stream without waiting for ready');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// The echo handler creates a bidirectional stream when a WebTransport session
// is established. Accept the bidirectional stream.
const stream_reader = wt.incomingBidirectionalStreams.getReader();
const { value: bidi_stream } = await stream_reader.read();
stream_reader.releaseLock();
// Write a message to the writable end, and close it.
const encoder = new TextEncoderStream();
encoder.readable.pipeTo(bidi_stream.writable);
const writer = encoder.writable.getWriter();
await writer.write('Hello World');
await writer.close();
// Read the data on the readable end.
const reply = await read_stream_as_string(bidi_stream.readable);
// Check that the message from the readable end matches the writable end.
assert_equals(reply, 'Hello World');
}, 'WebTransport server should be able to accept and handle a bidirectional stream');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// Create a unidirectional stream.
const writable = await wt.createUnidirectionalStream();
// Write a message to the writable end, and close it.
const encoder = new TextEncoderStream();
encoder.readable.pipeTo(writable);
const writer = encoder.writable.getWriter();
await writer.write('Hello World');
await writer.close();
// The echo handler creates a new unidirectional stream to echo back data from
// the server to client. Accept the unidirectional stream.
const readable = wt.incomingUnidirectionalStreams;
const stream_reader = readable.getReader();
const { value: recv_stream } = await stream_reader.read();
stream_reader.releaseLock();
// Read the data on the readable end.
const reply = await read_stream_as_string(recv_stream);
// Make sure the message on the writable and readable ends of the streams
// match.
assert_equals(reply, 'Hello World');
}, 'WebTransport client should be able to create, accept, and handle a unidirectional stream');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
// Create a unidirectional stream.
const writable = await wt.createUnidirectionalStream();
// Write a message to the writable end, and close it.
const encoder = new TextEncoderStream();
encoder.readable.pipeTo(writable);
const writer = encoder.writable.getWriter();
await writer.write('Hello World');
await writer.close();
// The echo handler creates a new unidirectional stream to echo back data from
// the server to client. Accept the unidirectional stream.
const readable = wt.incomingUnidirectionalStreams;
const stream_reader = readable.getReader();
const { value: recv_stream } = await stream_reader.read();
stream_reader.releaseLock();
// Read the data on the readable end.
const reply = await read_stream_as_string(recv_stream);
// Make sure the message on the writable and readable ends of the streams
// match.
assert_equals(reply, 'Hello World');
}, 'WebTransport client should be able to create, accept, and handle a unidirectional stream without waiting for ready');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// The echo handler creates a bidirectional stream when a WebTransport session
// is established. Accept the bidirectional stream.
const stream_reader = wt.incomingBidirectionalStreams.getReader();
const {value: bidi_stream} = await stream_reader.read();
stream_reader.releaseLock();
// Write data to the writable end, and close it.
const buffer_size = 256;
const data = new Uint8Array(buffer_size);
for (let i = 0; i < data.byteLength; ++i) {
data[i] = i;
}
const writer = bidi_stream.writable.getWriter();
writer.write(data);
await writer.close();
// Read the data on the readable end and check if it matches the writable end.
const reader = bidi_stream.readable.getReader({mode: 'byob'});
assert_true(reader instanceof ReadableStreamBYOBReader);
const half_buffer_size = buffer_size / 2;
for (let i = 0; i < 2; i++) {
let buffer = new ArrayBuffer(half_buffer_size);
buffer = await readInto(reader, buffer);
assert_array_equals(
new Uint8Array(buffer),
data.subarray(half_buffer_size * i, half_buffer_size * (i + 1)))
}
reader.releaseLock();
}, 'Can read data from a bidirectional stream with BYOB reader');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// Create a unidirectional stream.
const writable = await wt.createUnidirectionalStream();
// Write data to the writable end, and close it.
const buffer_size = 256;
const data = new Uint8Array(buffer_size);
for (let i = 0; i < data.byteLength; ++i) {
data[i] = i;
}
const writer = writable.getWriter();
writer.write(data);
await writer.close();
// The echo handler creates a new unidirectional stream to echo back data from
// the server to client. Accept the unidirectional stream.
const readable = wt.incomingUnidirectionalStreams;
const stream_reader = readable.getReader();
const {value: recv_stream} = await stream_reader.read();
stream_reader.releaseLock();
// Read the data on the readable end and check if it matches the writable end.
const reader = recv_stream.getReader({mode: 'byob'});
assert_true(reader instanceof ReadableStreamBYOBReader);
const half_buffer_size = buffer_size / 2;
let buffer = new ArrayBuffer(half_buffer_size);
for (let i = 0; i < 2; i++) {
buffer = await readInto(reader, buffer);
assert_array_equals(
new Uint8Array(buffer),
data.subarray(half_buffer_size * i, half_buffer_size * (i + 1)))
}
reader.releaseLock();
}, 'Can read data from a unidirectional stream with BYOB reader');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// Create a bidirectional stream.
const bidi_stream = await wt.createBidirectionalStream();
// Write a message to the writable end, and close it.
const writer = bidi_stream.writable.getWriter();
const bytes = new Uint8Array(16384);
const [reply] = await Promise.all([
read_stream(bidi_stream.readable),
writer.write(bytes),
writer.write(bytes),
writer.write(bytes),
writer.close()
]);
let len = 0;
for (chunk of reply) {
len += chunk.length;
}
// Check that the message from the readable end matches the writable end.
assert_equals(len, 3*bytes.length);
}, 'Transfer large chunks of data on a bidirectional stream');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// Create a unidirectional stream.
const uni_stream = await wt.createUnidirectionalStream();
// Write a message to the writable end, and close it.
const writer = uni_stream.getWriter();
const bytes = new Uint8Array(16384);
await Promise.all([
writer.write(bytes),
writer.write(bytes),
writer.write(bytes),
writer.close()
]);
// XXX Update once chrome fixes https://crbug.com/929585
// The echo handler creates a new unidirectional stream to echo back data from
// the server to client. Accept the unidirectional stream.
const readable = wt.incomingUnidirectionalStreams;
const stream_reader = readable.getReader();
const { value: recv_stream } = await stream_reader.read();
stream_reader.releaseLock();
// Read the data on the readable end.
const reply = await read_stream(recv_stream);
let len = 0;
for (chunk of reply) {
len += chunk.length;
}
// Check that the message from the readable end matches the writable end.
assert_equals(len, 3*bytes.length);
}, 'Transfer large chunks of data on a unidirectional stream');
promise_test(async t => {
// Establish a WebTransport session.
const wt = new WebTransport(webtransport_url('echo.py'));
await wt.ready;
// Create a bidirectional stream.
const bidi_stream = await wt.createBidirectionalStream();
// Close the writable end with no data at all.
const writer = bidi_stream.writable.getWriter();
writer.close();
// Read the data on the readable end.
const chunks = await read_stream(bidi_stream.readable);
assert_equals(chunks.length, 0);
await bidi_stream.readable.closed;
}, 'Closing the stream with no data still resolves the read request');
Codebase Browser
chromium