| /third_party/node/test/fixtures/wpt/streams/readable-streams/ |
| D | count-queuing-strategy-integration.any.js | 12 let controller; variable
16 controller = c;
23 assert_equals(controller.desiredSize, 0, '0 reads, 0 enqueues: desiredSize should be 0');
24 controller.enqueue('a');
25 assert_equals(controller.desiredSize, -1, '0 reads, 1 enqueue: desiredSize should be -1');
26 controller.enqueue('b');
27 assert_equals(controller.desiredSize, -2, '0 reads, 2 enqueues: desiredSize should be -2');
28 controller.enqueue('c');
29 assert_equals(controller.desiredSize, -3, '0 reads, 3 enqueues: desiredSize should be -3');
30 controller.enqueue('d');
[all …]
|
| D | floating-point-total-queue-size.any.js | 10 const { reader, controller } = setupTestStream();
12 controller.enqueue(2);
13 …assert_equals(controller.desiredSize, 0 - 2, 'desiredSize must be -2 after enqueueing such a chunk…
15 controller.enqueue(Number.MAX_SAFE_INTEGER);
16 assert_equals(controller.desiredSize, 0 - Number.MAX_SAFE_INTEGER - 2,
20 assert_equals(controller.desiredSize, 0 - Number.MAX_SAFE_INTEGER - 2 + 2,
25 …assert_equals(controller.desiredSize, 0, '[[queueTotalSize]] must clamp to 0 if it becomes negativ…
30 const { reader, controller } = setupTestStream();
32 controller.enqueue(1e-16);
33 …assert_equals(controller.desiredSize, 0 - 1e-16, 'desiredSize must be -1e16 after enqueueing such …
[all …]
|
| D | reentrant-strategies.any.js | 16 let controller; variable
20 controller = c;
26 controller.enqueue('b');
31 controller.enqueue('a');
32 controller.close();
38 let controller; variable
41 controller = c;
46 controller.close();
52 controller.enqueue('a');
59 let controller; variable
[all …]
|
| D | default-reader.any.js | 82 let controller; variable
85 controller = c;
94 controller.enqueue('a');
119 let controller; variable
122 controller = c;
129 controller.close();
136 let controller; variable
139 controller = c;
148 controller.close();
159 let controller; variable
[all …]
|
| D | garbage-collection.any.js | 7 let controller; variable
10 controller = c;
17 controller.close();
18 …assert_throws_js(TypeError, () => controller.close(), 'close should throw a TypeError the second t…
19 controller.error();
27 let controller; variable
31 controller = c;
37 return delay(50).then(() => controller.close()).then(() => closedPromise);
44 let controller; variable
48 controller = c;
[all …]
|
| /third_party/node/lib/internal/webstreams/ |
| D | readablestream.js | 583 this[kState].controller instanceof ReadableByteStreamController,
695 controller,
697 if (controller === undefined) {
713 readableByteStreamControllerRespond(controller, bytesWritten);
723 controller,
726 if (controller === undefined) {
737 readableByteStreamControllerRespondWithNewView(controller, view);
743 controller: this[kState].controller, property
755 function createReadableStreamBYOBRequest(controller, view) { argument
760 controller,
[all …]
|
| D | transformstream.js | 169 this[kState].controller));
262 controller: undefined,
290 controller: readableController,
348 async function defaultTransformAlgorithm(chunk, controller) { argument
349 transformStreamDefaultControllerEnqueue(controller, chunk);
395 controller: undefined, property
412 controller,
414 readableStreamDefaultControllerError(controller, error);
420 controller,
423 transformStreamDefaultControllerClearAlgorithms(controller);
[all …]
|
| D | util.js | 149 function dequeueValue(controller) { argument
150 assert(controller[kState].queue !== undefined);
151 assert(controller[kState].queueTotalSize !== undefined);
152 assert(controller[kState].queue.length);
156 } = ArrayPrototypeShift(controller[kState].queue);
157 controller[kState].queueTotalSize =
158 MathMax(0, controller[kState].queueTotalSize - size);
162 function resetQueue(controller) { argument
163 assert(controller[kState].queue !== undefined);
164 assert(controller[kState].queueTotalSize !== undefined);
[all …]
|
| D | writablestream.js | 187 controller: undefined,
361 controller: undefined,
655 controller,
660 controller[kState].abortController.abort(reason);
692 controller,
704 writableStreamDefaultControllerClose(controller);
728 controller,
731 assert(controller !== undefined);
738 controller[kState].started) {
880 stream[kState].controller[kError]();
[all …]
|
| /third_party/node/test/fixtures/wpt/dom/abort/ |
| D | event.any.js | 27 const controller = new AbortController(); constant
28 const signal = controller.signal;
29 assert_equals(controller.signal, signal,
31 controller.abort();
32 assert_equals(controller.signal, signal,
37 const controller = new AbortController(); constant
38 const signal = controller.signal;
43 controller.abort();
46 controller.abort();
53 const controller = new AbortController(); constant
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-whatwg-readablestream.js | 93 const controllerState = r1[kState].controller[kState];
106 const controllerState = r2[kState].controller[kState];
116 start: common.mustCall((controller) => {
117 assert(controller instanceof ReadableStreamDefaultController);
119 pull: common.mustCall((controller) => {
120 assert(controller instanceof ReadableStreamDefaultController);
130 start: common.mustCall(async (controller) => {
131 assert(controller instanceof ReadableStreamDefaultController);
133 pull: common.mustCall(async (controller) => {
134 assert(controller instanceof ReadableStreamDefaultController);
[all …]
|
| D | test-webstreams-compose.js | 24 transform: common.mustCall((chunk, controller) => {
25 controller.enqueue(chunk?.toString()?.replace(' ', '_'));
29 transform: common.mustCall((chunk, controller) => {
30 controller.enqueue(chunk?.toString()?.toUpperCase());
56 transform: common.mustCall((chunk, controller) => {
57 controller.enqueue(chunk.toString().toUpperCase());
80 transform: common.mustCall((chunk, controller) => {
81 controller.enqueue(chunk.toString().toUpperCase());
99 transform: common.mustCall((chunk, controller) => {
100 controller.enqueue(chunk.toString().toUpperCase());
[all …]
|
| D | test-webstreams-pipeline.js | 14 start(controller) { argument
15 c = controller;
36 start(controller) { argument
37 c = controller;
56 start(controller) { argument
57 c = controller;
62 transform(chunk, controller) { argument
63 controller.enqueue(chunk?.toString().toUpperCase());
85 transform(chunk, controller) { argument
86 controller.enqueue(chunk?.toString());
[all …]
|
| D | test-whatwg-events-add-event-listener-options-signal.js | 19 const controller = new AbortController(); constant
20 et.addEventListener('test', handler, { signal: controller.signal });
25 controller.abort();
31 et.addEventListener('test', handler, { signal: controller.signal }),
44 const controller = new AbortController(); constant
45 et.addEventListener('test', handler, { signal: controller.signal });
58 const controller = new AbortController(); constant
59 const options = { signal: controller.signal, once: true };
61 controller.abort();
72 const controller = new AbortController(); constant
[all …]
|
| D | test-whatwg-readablebytestream.js | 40 assert(r[kState].controller instanceof ReadableByteStreamController);
78 async start(controller) { argument
80 this.controller = controller;
83 async pull(controller) { argument
84 const byobRequest = controller.byobRequest;
98 this.controller.close();
122 assert(stream[kState].controller instanceof ReadableByteStreamController);
146 assert(stream[kState].controller instanceof ReadableByteStreamController);
164 assert(stream[kState].controller instanceof ReadableByteStreamController);
177 assert(stream[kState].controller instanceof ReadableByteStreamController);
[all …]
|
| D | test-webstreams-finished.js | 11 start(controller) { argument
12 controller.enqueue('asd');
13 controller.close();
29 start(controller) { argument
30 controller.error(new Error('asd'));
41 async start(controller) { argument
53 start(controller) { argument
54 controller.enqueue('asd');
55 controller.close();
74 start(controller) { argument
[all …]
|
| /third_party/node/test/fixtures/wpt/dom/events/ |
| D | AddEventListenerOptions-signal.any.js | 9 const controller = new AbortController();
10 et.addEventListener('test', handler, { signal: controller.signal });
15 controller.abort();
18 et.addEventListener('test', handler, { signal: controller.signal });
29 const controller = new AbortController();
30 et.addEventListener('test', handler, { signal: controller.signal });
42 const controller = new AbortController();
43 et.addEventListener('test', handler, { signal: controller.signal, once: true });
44 controller.abort();
55 const controller = new AbortController();
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/readable-byte-streams/ |
| D | general.any.js | 44 let controller; variable
53 controller = c;
58 desiredSize = controller.desiredSize;
316 let controller; variable
321 controller = c;
324 const byobRequest = controller.byobRequest;
400 let controller; variable
405 controller = c;
408 const byobRequest = controller.byobRequest;
499 let controller; variable
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/resources/ |
| D | recording-streams.js | 7 start(controller) { argument
8 controllerToCopyOver = controller;
11 return extras.start(controller);
16 pull(controller) { argument
20 return extras.pull(controller);
37 stream.controller = controllerToCopyOver;
47 start(controller) { argument
48 controllerToCopyOver = controller;
51 return extras.start(controller);
56 write(chunk, controller) { argument
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/transform-streams/ |
| D | terminate.any.js | 9 start(controller) { argument
10 controller.enqueue(0);
20 ts.controller.terminate();
31 start(controller) { argument
32 controller.enqueue(0);
33 controller.enqueue(1);
39 ts.controller.terminate();
48 start(controller) { argument
49 controller.enqueue(0);
50 controller.terminate();
[all …]
|
| D | reentrant-strategies.any.js | 19 let controller; variable
23 controller = c;
29 controller.enqueue('b');
42 let controller; variable
45 controller = c;
50 controller.terminate();
66 let controller; variable
69 controller = c;
73 controller.error(error1);
84 let controller; variable
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/writable-streams/ |
| D | error.any.js | 12 start(controller) { argument
13 controller.error(error1);
20 let controller; variable
23 controller = c;
27 controller.error(error1);
31 let controller; variable
34 controller = c;
37 controller.error(error1);
38 controller.error(error2);
43 let controller; variable
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/piping/ |
| D | flow-control.any.js | 13 start(controller) { argument
14 controller.enqueue('a');
15 controller.enqueue('b');
16 controller.close();
26 ws.controller.error(error1);
43 start(controller) { argument
44 controller.enqueue('b');
45 controller.close();
107 rs.controller.enqueue('b');
109 rs.controller.close();
[all …]
|
| D | close-propagation-forward.any.js | 12 start(controller) { argument
13 controller.close();
37 start(controller) { argument
38 controller.close();
66 start(controller) { argument
67 controller.close();
94 start(controller) { argument
95 controller.close();
117 start(controller) { argument
118 controller.close();
[all …]
|
| D | error-propagation-backward.any.js | 209 start(controller) { argument
210 controller.enqueue('Hello');
231 start(controller) { argument
232 controller.enqueue('Hello');
256 start(controller) { argument
257 controller.enqueue('Hello');
278 start(controller) { argument
279 controller.enqueue('a');
280 controller.enqueue('b');
281 controller.enqueue('c');
[all …]
|