Lines Matching refs:controller
88 * @param {TransformStreamDefaultController} controller;
93 * @param {TransformStreamDefaultController} controller;
100 * @param {TransformStreamDefaultController} controller
172 this[kState].controller));
265 controller: undefined,
295 controller: readableController,
344 async function defaultTransformAlgorithm(chunk, controller) {
345 transformStreamDefaultControllerEnqueue(controller, chunk);
391 controller: undefined,
408 controller,
410 readableStreamDefaultControllerError(controller, error);
416 controller,
419 transformStreamDefaultControllerClearAlgorithms(controller);
421 writable[kState].controller,
437 controller,
441 assert(stream[kState].controller === undefined);
442 controller[kState] = {
447 stream[kState].controller = controller;
453 const controller = new TransformStreamDefaultController(kSkipThrow);
463 controller,
468 function transformStreamDefaultControllerClearAlgorithms(controller) {
469 controller[kState].transformAlgorithm = undefined;
470 controller[kState].flushAlgorithm = undefined;
473 function transformStreamDefaultControllerEnqueue(controller, chunk) {
476 } = controller[kState];
481 controller: readableController,
499 function transformStreamDefaultControllerError(controller, error) {
500 transformStreamError(controller[kState].stream, error);
503 async function transformStreamDefaultControllerPerformTransform(controller, chunk) {
506 controller[kState].transformAlgorithm,
507 controller,
509 controller);
511 transformStreamError(controller[kState].stream, error);
516 function transformStreamDefaultControllerTerminate(controller) {
519 } = controller[kState];
525 controller: readableController,
536 controller,
551 controller,
555 return transformStreamDefaultControllerPerformTransform(controller, chunk);
565 controller,
570 controller[kState].flushAlgorithm,
571 controller,
572 controller);
573 transformStreamDefaultControllerClearAlgorithms(controller);
579 readableStreamDefaultControllerClose(readable[kState].controller);