Struct errorStream

pkg/telemetry/genai/genai_test.go:166–171

errorStream yields an optional finish-reason chunk then returns a transport error on the next Recv. When finishWithError is true it returns both the finish reason and the error in the same Recv call.

// transport error on the next Recv. When finishWithError is true it returns
// both the finish reason and the error in the same Recv call.
type errorStream struct {
	finishFirst     bool
	finishWithError bool
	sent            bool
	err             error
}

func (s *errorStream) Recv() (chat.MessageStreamResponse, error) {
	if s.finishWithError && !s.sent {