Lines Matching refs:controller
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);
144 start: common.mustCall((controller) => {
145 assert(controller instanceof ReadableByteStreamController);
157 start: common.mustCall(async (controller) => {
158 assert(controller instanceof ReadableByteStreamController);
170 start: common.mustCall(async (controller) => {
171 assert(controller instanceof ReadableByteStreamController);
173 pull: common.mustCall(async (controller) => {
174 assert(controller instanceof ReadableByteStreamController);
270 start(controller) {
271 controller.enqueue(data);
272 controller.close();
289 start(controller) {
290 controller.close();
385 start(controller) {
386 controller.enqueue(Buffer.from('hello'));
406 start(controller) {
407 controller.close();
424 start(controller) {
425 controller.close();
436 start(controller) {
437 controller.close();
450 start(controller) {
451 controller.close();
471 start(controller) {
472 controller.close();
492 start(controller) {
493 c = controller;
513 start(controller) {
514 controller.close();
536 start(controller) {
537 c = controller;
576 start(controller) {
577 controller.error(error);
590 start(controller) {
591 controller.error(error);
605 async start(controller) {
621 start(controller) {
622 controller.enqueue(buf1);
623 controller.enqueue(buf2);
624 doClose = controller.close.bind(controller);
647 start(controller) {
648 controller.enqueue(buf1);
649 controller.enqueue(buf2);
667 start(controller) {
668 controller.enqueue('a');
669 controller.enqueue('b');
670 controller.close();
698 start(controller) {
699 controller.enqueue('a');
700 controller.enqueue('b');
726 start(controller) {
727 controller.enqueue('a');
728 controller.enqueue('b');
729 controller.close();
807 start(controller) {
808 c = controller;
823 start(controller) {
824 c = controller;
845 pull(controller) {
847 controller.enqueue(pullCount);
871 start(controller) {
872 controller.enqueue('a');
885 start(controller) {
886 controller.enqueue('a');
887 controller.enqueue('b');
906 start(controller) {
907 controller.enqueue('a');
908 controller.enqueue('b');
909 controller.close();
937 pull(controller) {
938 controller.enqueue(++calls);
959 start(controller) {
960 controller.enqueue('a');
961 controller.enqueue('b');
962 controller.enqueue('c');
981 start(controller) {
982 controller.enqueue('a');
983 controller.enqueue('b');
984 controller.enqueue('c');
985 controller.close();
1008 pull(controller) {
1009 controller.enqueue(++calls);
1025 pull: common.mustCall((controller) => controller.close())
1036 pull: common.mustCall((controller) => controller.error(error))
1048 pull: common.mustCall((controller) => {
1049 controller.error(error);
1062 start: common.mustCall((controller) => {
1063 controller.enqueue('a');
1064 controller.close();
1065 assert.throws(() => controller.enqueue('b'), {
1077 start: common.mustCall((controller) => {
1078 controller.close();
1079 assert.throws(() => controller.enqueue('b'), {
1094 start(controller) {
1097 controller.enqueue('a');
1129 start(controller) {
1130 assert.strictEqual(controller.desiredSize, 10);
1131 controller.close();
1132 assert.strictEqual(controller.desiredSize, 0);
1144 start(controller) {
1145 assert.strictEqual(controller.desiredSize, 10);
1146 controller.error();
1147 assert.strictEqual(controller.desiredSize, null);
1165 start(controller) {
1166 assert.strictEqual(controller.desiredSize, 1);
1167 controller.enqueue('a');
1168 assert.strictEqual(controller.desiredSize, 0);
1169 controller.enqueue('a');
1170 assert.strictEqual(controller.desiredSize, -1);
1171 controller.enqueue('a');
1172 assert.strictEqual(controller.desiredSize, -2);
1173 controller.enqueue('a');
1174 assert.strictEqual(controller.desiredSize, -3);
1184 start(controller) {
1185 c = controller;
1210 start(controller) {
1211 c = controller;
1226 start(controller) {
1229 controller.enqueue(chunk);
1233 controller.close();
1236 controller.error(error);
1446 let controller;
1448 start(c) { controller = c; }
1464 inspect(controller),
1467 inspect(controller, { depth: null }),
1470 inspect(controller, { depth: 0 }),
1522 start(controller) {
1523 controller.enqueue('hello');
1545 let controller;
1547 start(c) { controller = c; }
1550 controller[kState].pendingPullIntos = [{}];
1551 assert.throws(() => readableByteStreamControllerRespond(controller, 0), {
1557 assert.throws(() => readableByteStreamControllerRespond(controller, 1), {
1561 assert(!readableStreamDefaultControllerCanCloseOrEnqueue(controller));
1562 readableStreamDefaultControllerEnqueue(controller);
1563 readableByteStreamControllerClose(controller);
1564 readableByteStreamControllerEnqueue(controller, new Uint8Array(1));
1569 start(controller) {
1570 controller.enqueue('a');
1571 controller.close();
1586 start(controller) {
1587 controller.close();
1602 start(controller) {
1618 pull: common.mustCall((controller) => {
1619 controller.error(new Error());
1633 pull: common.mustCall((controller) => {
1634 controller.error(new Error());
1649 start(controller) {
1650 controller.close();
1665 pull: common.mustCall((controller) => {
1666 const view = controller.byobRequest.view;
1673 controller.byobRequest.respondWithNewView(dest);