Lines Matching refs:kState
49 kState,
172 this[kState].controller));
188 return this[kState].readable;
198 return this[kState].writable;
205 backpressure: this[kState].backpressure,
215 } = this[kState];
237 return [ this[kState].readable, this[kState].writable ];
241 this[kState].readable = readable;
242 this[kState].writable = writable;
256 this[kState] = {
290 } = this[kState];
293 } = stream[kState];
296 } = readable[kState];
326 stream: this[kState].stream,
388 stream[kState] = {
406 } = stream[kState];
409 } = readable[kState];
418 } = stream[kState];
421 writable[kState].controller,
423 if (stream[kState].backpressure)
428 assert(stream[kState].backpressure !== backpressure);
429 if (stream[kState].backpressureChange.promise !== undefined)
430 stream[kState].backpressureChange.resolve?.();
431 stream[kState].backpressureChange = createDeferredPromise();
432 stream[kState].backpressure = backpressure;
441 assert(stream[kState].controller === undefined);
442 controller[kState] = {
447 stream[kState].controller = controller;
469 controller[kState].transformAlgorithm = undefined;
470 controller[kState].flushAlgorithm = undefined;
476 } = controller[kState];
479 } = stream[kState];
482 } = readable[kState];
489 throw readable[kState].storedError;
493 if (backpressure !== stream[kState].backpressure) {
500 transformStreamError(controller[kState].stream, error);
506 controller[kState].transformAlgorithm,
511 transformStreamError(controller[kState].stream, error);
519 } = controller[kState];
522 } = stream[kState];
526 } = readable[kState];
537 } = stream[kState];
538 assert(writable[kState].state === 'writable');
539 if (stream[kState].backpressure) {
540 const backpressureChange = stream[kState].backpressureChange.promise;
546 } = stream[kState];
547 if (writable[kState].state === 'erroring')
548 throw writable[kState].storedError;
549 assert(writable[kState].state === 'writable');
566 } = stream[kState];
570 controller[kState].flushAlgorithm,
577 if (readable[kState].state === 'errored')
578 throw readable[kState].storedError;
579 readableStreamDefaultControllerClose(readable[kState].controller);
583 throw readable[kState].storedError;
588 assert(stream[kState].backpressure);
589 assert(stream[kState].backpressureChange.promise !== undefined);
591 return stream[kState].backpressureChange.promise;