Function start

packages/start-server-core/src/server-functions-handler.ts:245–261

(controller)

            // Create a stream of JSON chunks (NDJSON style)
            const jsonStream = new ReadableStream<string>({
              start(controller) {
                callbacks.onParse = (value) => {
                  controller.enqueue(JSON.stringify(value) + '\n')
                }
                callbacks.onDone = () => {
                  try {
                    controller.close()
                  } catch {
                    // Already closed
                  }
                }
                callbacks.onError = (error) => controller.error(error)
                // Emit initial body if we have one
                if (nonStreamingBody !== undefined) {
                  callbacks.onParse(nonStreamingBody)
                }
              },
            })

            // Create multiplexed stream with JSON and raw streams