Lines Matching refs:kState

48   kState,
169           this[kState].controller));
185     return this[kState].readable;
195     return this[kState].writable;
202       backpressure: this[kState].backpressure,
212     } = this[kState];
234     return [ this[kState].readable, this[kState].writable ];
238     this[kState].readable = readable;
239     this[kState].writable = writable;
253       this[kState] = {
285     } = this[kState];
288     } = stream[kState];
291     } = readable[kState];
321       stream: this[kState].stream,
392   stream[kState] = {
410   } = stream[kState];
413   } = readable[kState];
422   } = stream[kState];
425     writable[kState].controller,
427   if (stream[kState].backpressure)
432   assert(stream[kState].backpressure !== backpressure);
433   if (stream[kState].backpressureChange.promise !== undefined)
434     stream[kState].backpressureChange.resolve?.();
435   stream[kState].backpressureChange = createDeferredPromise();
436   stream[kState].backpressure = backpressure;
445   assert(stream[kState].controller === undefined);
446   controller[kState] = {
451   stream[kState].controller = controller;
473   controller[kState].transformAlgorithm = undefined;
474   controller[kState].flushAlgorithm = undefined;
480   } = controller[kState];
483   } = stream[kState];
486   } = readable[kState];
493     throw readable[kState].storedError;
497   if (backpressure !== stream[kState].backpressure) {
504   transformStreamError(controller[kState].stream, error);
510       controller[kState].transformAlgorithm,
515     transformStreamError(controller[kState].stream, error);
523   } = controller[kState];
526   } = stream[kState];
530   } = readable[kState];
541   } = stream[kState];
542   assert(writable[kState].state === 'writable');
543   if (stream[kState].backpressure) {
544     const backpressureChange = stream[kState].backpressureChange.promise;
550         } = stream[kState];
551         if (writable[kState].state === 'erroring')
552           throw writable[kState].storedError;
553         assert(writable[kState].state === 'writable');
570   } = stream[kState];
574       controller[kState].flushAlgorithm,
581       if (readable[kState].state === 'errored')
582         throw readable[kState].storedError;
583       readableStreamDefaultControllerClose(readable[kState].controller);
587       throw readable[kState].storedError;
592   assert(stream[kState].backpressure);
593   assert(stream[kState].backpressureChange.promise !== undefined);
595   return stream[kState].backpressureChange.promise;