MCPcopy
hub / github.com/di-sukharev/opencommit / It

Function It

out/cli.cjs:7972–7979  ·  view source on GitHub ↗
(e3, t2, r3, o3)

Source from the content-addressed store, hash-verified

7970 return !e3._closeRequested && "readable" === e3._controlledReadableStream._state;
7971}
7972function It(e3, t2, r3, o3) {
7973 const n2 = Object.create(ReadableStreamDefaultController.prototype);
7974 let a4, i3, l3;
7975 a4 = void 0 !== t2.start ? () => t2.start(n2) : () => {
7976 }, i3 = void 0 !== t2.pull ? () => t2.pull(n2) : () => c3(void 0), l3 = void 0 !== t2.cancel ? (e4) => t2.cancel(e4) : () => c3(void 0), function(e4, t3, r4, o4, n3, a5, i4) {
7977 t3._controlledReadableStream = e4, t3._queue = void 0, t3._queueTotalSize = void 0, ce2(t3), t3._started = false, t3._closeRequested = false, t3._pullAgain = false, t3._pulling = false, t3._strategySizeAlgorithm = i4, t3._strategyHWM = a5, t3._pullAlgorithm = o4, t3._cancelAlgorithm = n3, e4._readableStreamController = t3, b6(c3(r4()), () => (t3._started = true, At(t3), null), (e5) => (zt(t3, e5), null));
7978 }(e3, n2, a4, i3, l3, r3, o3);
7979}
7980function Dt(e3) {
7981 return new TypeError(`ReadableStreamDefaultController.prototype.${e3} can only be used on a ReadableStreamDefaultController`);
7982}

Callers 1

constructorMethod · 0.85

Calls 9

c3Function · 0.85
ce2Function · 0.85
b6Function · 0.85
AtFunction · 0.85
ztFunction · 0.85
createMethod · 0.45
startMethod · 0.45
pullMethod · 0.45
cancelMethod · 0.45

Tested by

no test coverage detected