MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / getResponsePromise

Function getResponsePromise

out/cli.cjs:79115–79125  ·  view source on GitHub ↗
(stream4)

Source from the content-addressed store, hash-verified

79113 const inputStream = response.body.pipeThrough(new TextDecoderStream("utf8", { fatal: true }));
79114 const responseStream = getResponseStream(inputStream);
79115 const [stream1, stream22] = responseStream.tee();
79116 return {
79117 stream: generateResponseSequence(stream1),
79118 response: getResponsePromise(stream22)
79119 };
79120}
79121async function getResponsePromise(stream4) {
79122 const allResponses = [];
79123 const reader = stream4.getReader();
79124 while (true) {
79125 const { done, value } = await reader.read();
79126 if (done) {
79127 return addHelpers(aggregateResponses(allResponses));
79128 }

Callers 1

processStreamFunction · 0.85

Calls 5

addHelpersFunction · 0.85
aggregateResponsesFunction · 0.85
getReaderMethod · 0.45
readMethod · 0.45
pushMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…