MCPcopy Create free account
hub / github.com/xerrors/Yuxi / resolveChunkThreadId

Function resolveChunkThreadId

web/src/composables/useAgentRunStream.js:24–31  ·  view source on GitHub ↗
({ envelope, payload, chunk, fallbackThreadId })

Source from the content-addressed store, hash-verified

22}
23
24const resolveChunkThreadId = ({ envelope, payload, chunk, fallbackThreadId }) => {
25 return (
26 getThreadIdFromObject(envelope) ||
27 getThreadIdFromObject(payload) ||
28 getThreadIdFromObject(chunk) ||
29 fallbackThreadId
30 )
31}
32
33const processRunSseResponse = async (response, onEvent) => {
34 if (!response || !response.body) return

Callers 1

startRunStreamFunction · 0.85

Calls 1

getThreadIdFromObjectFunction · 0.85

Tested by

no test coverage detected