MCPcopy Create free account
hub / github.com/angular/dev-infra / dump

Method dump

github-actions/browserstack/set-browserstack-env.js:9754–9790  ·  view source on GitHub ↗
(opts)

Source from the content-addressed store, hash-verified

9752 return this[kBody];
9753 }
9754 dump(opts) {
9755 return __async(this, null, function* () {
9756 let limit = Number.isFinite(opts == null ? void 0 : opts.limit) ? opts.limit : 128 * 1024;
9757 const signal = opts == null ? void 0 : opts.signal;
9758 if (signal != null && (typeof signal !== "object" || !("aborted" in signal))) {
9759 throw new InvalidArgumentError("signal must be an AbortSignal");
9760 }
9761 signal == null ? void 0 : signal.throwIfAborted();
9762 if (this._readableState.closeEmitted) {
9763 return null;
9764 }
9765 return yield new Promise((resolve2, reject) => {
9766 if (this[kContentLength] > limit) {
9767 this.destroy(new AbortError());
9768 }
9769 const onAbort = () => {
9770 var _a;
9771 this.destroy((_a = signal.reason) != null ? _a : new AbortError());
9772 };
9773 signal == null ? void 0 : signal.addEventListener("abort", onAbort);
9774 this.on("close", function() {
9775 var _a;
9776 signal == null ? void 0 : signal.removeEventListener("abort", onAbort);
9777 if (signal == null ? void 0 : signal.aborted) {
9778 reject((_a = signal.reason) != null ? _a : new AbortError());
9779 } else {
9780 resolve2(null);
9781 }
9782 }).on("error", noop).on("data", function(chunk) {
9783 limit -= chunk.length;
9784 if (limit <= 0) {
9785 this.destroy();
9786 }
9787 }).resume();
9788 });
9789 });
9790 }
9791 };
9792 function isLocked(self) {
9793 return self[kBody] && self[kBody].locked === true || self[kConsume];

Callers

nothing calls this directly

Calls 4

__asyncFunction · 0.70
destroyMethod · 0.45
resumeMethod · 0.45
onMethod · 0.45

Tested by

no test coverage detected