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

Function consumeEnd

github-actions/browserstack/set-browserstack-env.js:9889–9907  ·  view source on GitHub ↗
(consume2)

Source from the content-addressed store, hash-verified

9887 body: []
9888 };
9889 stream.on("error", function(err) {
9890 consumeFinish(this[kConsume], err);
9891 }).on("close", function() {
9892 if (this[kConsume].body !== null) {
9893 consumeFinish(this[kConsume], new RequestAbortedError());
9894 }
9895 });
9896 consumeStart(stream[kConsume]);
9897 });
9898 }
9899 });
9900 });
9901 }
9902 function consumeStart(consume2) {
9903 if (consume2.body === null) {
9904 return;
9905 }
9906 const { _readableState: state } = consume2.stream;
9907 if (state.bufferIndex) {
9908 const start = state.bufferIndex;
9909 const end = state.buffer.length;
9910 for (let n = start; n < end; n++) {

Callers 1

consumeStartFunction · 0.70

Calls 4

chunksDecodeFunction · 0.70
chunksConcatFunction · 0.70
consumeFinishFunction · 0.70
destroyMethod · 0.45

Tested by

no test coverage detected