Method resolve

internal/llm/llm.go:594–605

()

// abort on cancellation instead of blocking on an undrained buffer.
// serverStreamError is an error the SERVER reported inside the SSE stream, as
// opposed to a transport failure. Typed so the replay path can tell the two
// apart: resending a request the server already refused just repeats the refusal.
type serverStreamError struct{ msg string }

func (e *serverStreamError) Error() string {
	return "the server reported a stream error: " + e.msg
}

func readSSE(parent context.Context, body io.Reader, budget cloud.BudgetStatus, out chan<- Event, onFrame func(output bool)) (*chmctx.Message, int, int, error) {
	scanner := bufio.NewScanner(body)
	scanner.Buffer(make([]byte, 1<<16), 4<<20)

	var (
		fullContent  strings.Builder
		slots        = map[int]*toolSlot{}