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

Function processStream

out/cli.cjs:79106–79114  ·  view source on GitHub ↗
(response)

Source from the content-addressed store, hash-verified

79104 function reject(value) {
79105 resume2("throw", value);
79106 }
79107 function settle2(f4, v5) {
79108 if (f4(v5), q6.shift(), q6.length) resume2(q6[0][0], q6[0][1]);
79109 }
79110}
79111var responseLineRE = /^data\: (.*)(?:\n\n|\r\r|\r\n\r\n)/;
79112function processStream(response) {
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),

Callers 1

generateContentStreamFunction · 0.85

Calls 5

getResponseStreamFunction · 0.85
generateResponseSequenceFunction · 0.85
getResponsePromiseFunction · 0.85
pipeThroughMethod · 0.45
teeMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…