how can i handle streaming response by gozero

[qianjiangchao1992]

我现在处理GPT流式返回，我用Gin可以实现，Demo代码如下：

r.GET("/stream", func(c *gin.Context) {
		chanStream := make(chan string, 100)
		c.Header("Content-Type", "text/event-stream; charset=utf-8")
		go http.GetData("三体是什么？请用100字介绍", chanStream)
		c.Stream(func(w io.Writer) bool {
			if msg, ok := <-chanStream; ok {
				fmt.Println("msg:" + msg)
				outputBytes := bytes.NewBufferString(msg)
				c.Writer.Write(append(outputBytes.Bytes(), []byte("\n")...))
				return true
			}
			return false
})

如果我想用go-zero该怎么处理，我看了下httpx这个包，更多是writeJson没找到处理流式写入方法

[Issues-translate-bot]

Bot detected the issue body's language is not English, translate it automatically. 👯👭🏻🧑‍🤝‍🧑👫🧑🏿‍🤝‍🧑🏻👩🏾‍🤝‍👨🏿👬🏿

---

I am now processing GPT streaming returns. I can use Gin to achieve this. The Demo code is as follows:
r.GET("/stream", func(c *gin.Context) {
chanStream := make(chan string, 100)
c.Header("Content-Type", "text/event-stream; charset=utf-8")
go http.GetData("What is Three-Body Problem? Please introduce it in 100 words", chanStream)
c.Stream(func(w io.Writer) bool {
if msg, ok := <-chanStream; ok {
fmt.Println("msg:" + msg)
outputBytes := bytes.NewBufferString(msg)
c.Writer.Write(append(outputBytes.Bytes(), []byte("\n")...))
return true
}
return false
})
What should I do if I want to use go-zero? I looked at the httpx package and found that writeJson did not find a way to handle streaming writing.

[fynxiu]

Regarding your issue with handling streaming data using go-zero, it seems that go-zero currently doesn't offer built-in support for EventStream handling like Gin does. You might need to implement the streaming logic yourself by referencing other code examples.