Lines Matching defs:stream
289 stream,
293 } = stream[kState];
326 stream: this[kState].stream,
349 stream,
360 return transformStreamDefaultSinkWriteAlgorithm(stream, chunk);
363 return transformStreamDefaultSinkAbortAlgorithm(stream, reason);
366 return transformStreamDefaultSinkCloseAlgorithm(stream);
377 return transformStreamDefaultSourcePullAlgorithm(stream);
380 transformStreamErrorWritableAndUnblockWrite(stream, reason);
388 stream[kState] = {
400 transformStreamSetBackpressure(stream, true);
403 function transformStreamError(stream, error) {
406 } = stream[kState];
411 transformStreamErrorWritableAndUnblockWrite(stream, error);
414 function transformStreamErrorWritableAndUnblockWrite(stream, error) {
418 } = stream[kState];
423 if (stream[kState].backpressure)
424 transformStreamSetBackpressure(stream, false);
427 function transformStreamSetBackpressure(stream, 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;
436 stream,
440 assert(isTransformStream(stream));
441 assert(stream[kState].controller === undefined);
443 stream,
447 stream[kState].controller = controller;
451 stream,
462 stream,
475 stream,
479 } = stream[kState];
488 transformStreamErrorWritableAndUnblockWrite(stream, error);
493 if (backpressure !== stream[kState].backpressure) {
495 transformStreamSetBackpressure(stream, true);
500 transformStreamError(controller[kState].stream, error);
511 transformStreamError(controller[kState].stream, error);
518 stream,
522 } = stream[kState];
529 stream,
533 function transformStreamDefaultSinkWriteAlgorithm(stream, chunk) {
537 } = stream[kState];
539 if (stream[kState].backpressure) {
540 const backpressureChange = stream[kState].backpressureChange.promise;
546 } = stream[kState];
558 async function transformStreamDefaultSinkAbortAlgorithm(stream, reason) {
559 transformStreamError(stream, reason);
562 function transformStreamDefaultSinkCloseAlgorithm(stream) {
566 } = stream[kState];
582 transformStreamError(stream, error);
587 function transformStreamDefaultSourcePullAlgorithm(stream) {
588 assert(stream[kState].backpressure);
589 assert(stream[kState].backpressureChange.promise !== undefined);
590 transformStreamSetBackpressure(stream, false);
591 return stream[kState].backpressureChange.promise;