Lines Matching refs:ws
14 const ws = recordingWritableStream({
20 const writer = ws.getWriter();
24 assert_array_equals(ws.events, []);
25 return ws;
36 const ws = recordingWritableStream({
43 return promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error').then(() => {
45 assert_array_equals(ws.events, []);
49 promise_rejects_exactly(t, error2, ws.getWriter().closed, 'the writable stream must be errored with error2')
63 .then(ws => promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error'))
77 const ws = recordingWritableStream({
83 return promise_rejects_exactly(t, error1, rs.pipeTo(ws, { preventAbort: true }),
87 assert_array_equals(ws.events, []);
91 promise_rejects_exactly(t, error2, ws.getWriter().closed, 'the writable stream must be errored with error2')
104 .then(ws => promise_rejects_exactly(t, error1, rs.pipeTo(ws, { preventAbort: true }),
120 const ws = recordingWritableStream();
121 const writer = ws.getWriter();
125 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error').then(() => {
127 assert_array_equals(ws.events, ['abort', error1]);
131 promise_rejects_exactly(t, error1, ws.getWriter().closed,
146 const ws = recordingWritableStream();
147 const writer = ws.getWriter();
152 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error').then(() => {
154 assert_array_equals(ws.events, ['close']);
158 ws.getWriter().closed,
172 const ws = recordingWritableStream({
178 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error').then(() => {
180 assert_array_equals(ws.events, []);
184 promise_rejects_exactly(t, error1, ws.getWriter().closed, 'the writable stream must be errored with error1')
197 .then(ws => promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error'))
212 const ws = recordingWritableStream();
213 const writer = ws.getWriter();
217 return rs.pipeTo(ws).then(() => {
219 assert_array_equals(ws.events, ['close']);
223 ws.getWriter().closed