MCPcopy Create free account
hub / github.com/Noumena-Network/code / start

Function start

src/services/api/openAICompatInferenceReceiptReplay.ts:94–99  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

92 const events = buildOpenAICompatReplaySseEvents(receipt)
93 const stream = new ReadableStream({
94 start(controller) {
95 for (const event of events) {
96 controller.enqueue(new TextEncoder().encode(event))
97 }
98 controller.close()
99 },
100 })
101
102 return new Response(stream, {

Callers

nothing calls this directly

Calls 2

enqueueMethod · 0.45
closeMethod · 0.45

Tested by

no test coverage detected