MCPcopy Create free account
hub / github.com/Rfym21/Qwen2API / collectNestedValues

Function collectNestedValues

src/controllers/chat.image.video.js:160–175  ·  view source on GitHub ↗
(payload, visited = new Set())

Source from the content-addressed store, hash-verified

158const parseSsePayloads = (buffer, flush = false) => {
159 const input = flush ? `${buffer}\n\n` : buffer
160 const events = input.split(/\r?\n\r?\n/)
161 const payloads = []
162 const remainBuffer = flush ? '' : (events.pop() || '')
163
164 for (const event of events) {
165 const dataLines = event
166 .split(/\r?\n/)
167 .filter(item => item.trim().startsWith('data:'))
168 .map(item => item.replace(/^data:\s*/, '').trim())
169 .filter(Boolean)
170
171 if (dataLines.length === 0) {
172 continue
173 }
174
175 const payload = dataLines.join('\n').trim()
176 if (payload && payload !== '[DONE]') {
177 payloads.push(payload)
178 }

Calls

no outgoing calls

Tested by

no test coverage detected