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

Method pipeThrough

out/cli.cjs:8782–8789  ·  view source on GitHub ↗
(e3, t2 = {})

Source from the content-addressed store, hash-verified

8780 }(this);
8781 }
8782 pipeThrough(e3, t2 = {}) {
8783 if (!H5(this)) throw Kt("pipeThrough");
8784 $5(e3, 1, "pipeThrough");
8785 const r3 = xt(e3, "First parameter"), o3 = Ht(t2, "Second parameter");
8786 if (this.locked) throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked ReadableStream");
8787 if (r3.writable.locked) throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked WritableStream");
8788 return m4(kt(this, r3.writable, o3.preventClose, o3.preventAbort, o3.preventCancel, o3.signal)), r3.readable;
8789 }
8790 pipeTo(e3, t2 = {}) {
8791 if (!H5(this)) return d6(Kt("pipeTo"));
8792 if (void 0 === e3) return d6("Parameter 1 is required in 'pipeTo'.");

Callers 4

constructorMethod · 0.45
fetchFinaleFunction · 0.45
getOaiSSEsFunction · 0.45
processStreamFunction · 0.45

Calls 7

H5Function · 0.85
KtFunction · 0.85
$5Function · 0.85
xtFunction · 0.85
HtFunction · 0.85
m4Function · 0.85
ktFunction · 0.85

Tested by

no test coverage detected