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

Function chunksDecode

github-actions/bazel/configure-remote/configure-remote.js:9864–9872  ·  view source on GitHub ↗
(chunks, length)

Source from the content-addressed store, hash-verified

9862 }
9863 function consume(stream, type) {
9864 return __async(this, null, function* () {
9865 assert(!stream[kConsume]);
9866 return new Promise((resolve2, reject) => {
9867 var _a;
9868 if (isUnusable(stream)) {
9869 const rState = stream._readableState;
9870 if (rState.destroyed && rState.closeEmitted === false) {
9871 stream.on("error", (err) => {
9872 reject(err);
9873 }).on("close", () => {
9874 reject(new TypeError("unusable"));
9875 });

Callers 2

consumeEndFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected