MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / TransformStreamDefaultControllerEnqueue

Function TransformStreamDefaultControllerEnqueue

out/cli.cjs:14556–14572  ·  view source on GitHub ↗
(controller, chunk)

Source from the content-addressed store, hash-verified

14554 controller._cancelAlgorithm = void 0;
14555 }
14556 function TransformStreamDefaultControllerEnqueue(controller, chunk) {
14557 const stream4 = controller._controlledTransformStream;
14558 const readableController = stream4._readable._readableStreamController;
14559 if (!ReadableStreamDefaultControllerCanCloseOrEnqueue(readableController)) {
14560 throw new TypeError("Readable side is not in a state that permits enqueue");
14561 }
14562 try {
14563 ReadableStreamDefaultControllerEnqueue(readableController, chunk);
14564 } catch (e3) {
14565 TransformStreamErrorWritableAndUnblockWrite(stream4, e3);
14566 throw stream4._readable._storedError;
14567 }
14568 const backpressure = ReadableStreamDefaultControllerHasBackpressure(readableController);
14569 if (backpressure !== stream4._backpressure) {
14570 TransformStreamSetBackpressure(stream4, true);
14571 }
14572 }
14573 function TransformStreamDefaultControllerError(controller, e3) {
14574 TransformStreamError(controller._controlledTransformStream, e3);
14575 }

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…