Function pumpRawStream

packages/start-server-core/src/frame-protocol.ts:169–197

(
        streamId: number,
        stream: ReadableStream<Uint8Array>,
      )

      // Pump a single raw stream with its streamId
      const pumpRawStream = async (
        streamId: number,
        stream: ReadableStream<Uint8Array>,
      ) => {
        const reader = stream.getReader()
        cancelReaders.push(() => {
          // Catch async rejection - reader may already be released
          reader.cancel().catch(() => {})
        })
        try {
          // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
          while (true) {
            const { done, value } = await reader.read()
            // Check cancelled after await - flag may have changed while waiting
            if (cancelled) break
            if (done) {
              safeEnqueue(encodeEndFrame(streamId))
              break
            }
            safeEnqueue(encodeChunkFrame(streamId, value))
          }
        } catch (error) {
          // Stream error - send ERROR frame (non-fatal, other streams continue)
          safeEnqueue(encodeErrorFrame(streamId, error))
        } finally {
          reader.releaseLock()
          checkComplete()
        }
      }

      // Start all pumps concurrently
      pumpJSON()