Function writeOpenAIStream

test/task_tools_parity_test.go:602–607

(w http.ResponseWriter, text string, inputTokens, outputTokens int)

		Destructive:     coretools.BoolPtr(false),
	}}, started: started}
}

func (t *blockingTool) Execute(ctx context.Context, _ coretools.ExecutionContext, _ any) (string, error) {
	close(t.started)
	<-ctx.Done()
	return "", ctx.Err()
}

func writeOpenAIStream(w http.ResponseWriter, text string, inputTokens, outputTokens int) {