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

Method read

out/cli.cjs:8241–8252  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

8239 return K5(this) ? void 0 === this._ownerReadableStream ? d6(k6("cancel")) : P3(this, e3) : d6(ee2("cancel"));
8240 }
8241 read() {
8242 if (!K5(this)) return d6(ee2("read"));
8243 if (void 0 === this._ownerReadableStream) return d6(k6("read from"));
8244 let e3, t2;
8245 const r3 = u2((r4, o3) => {
8246 e3 = r4, t2 = o3;
8247 });
8248 return function(e4, t3) {
8249 const r4 = e4._ownerReadableStream;
8250 r4._disturbed = true, "closed" === r4._state ? t3._closeSteps() : "errored" === r4._state ? t3._errorSteps(r4._storedError) : r4._readableStreamController[q5](t3);
8251 }(this, { _chunkSteps: (t3) => e3({ value: t3, done: false }), _closeSteps: () => e3({ value: void 0, done: true }), _errorSteps: (e4) => t2(e4) }), r3;
8252 }
8253 releaseLock() {
8254 if (!K5(this)) throw ee2("releaseLock");
8255 void 0 !== this._ownerReadableStream && function(e3) {

Callers 15

O5Function · 0.45
g5Function · 0.45
w7Function · 0.45
m5Function · 0.45
_nextStepsMethod · 0.45
pullAlgorithmFunction · 0.45
readFunction · 0.45
startFunction · 0.45
discardResponseBodyFunction · 0.45
readAllBytesFunction · 0.45

Calls 15

K5Function · 0.85
d6Function · 0.85
ee2Function · 0.85
k6Function · 0.85
u2Function · 0.85
e3Function · 0.85
FeFunction · 0.85
DeFunction · 0.85
jeFunction · 0.85
weFunction · 0.85
peFunction · 0.85
veFunction · 0.85

Tested by

no test coverage detected