|
@@ -91,7 +91,7 @@ func DoChatCompletionsStream(ctx context.Context, client *openai.Client, chatInf
|
|
|
defer chatStream.Close()
|
|
|
for chatStream.Next() {
|
|
|
chunk := chatStream.Current()
|
|
|
- fmt.Fprintf(hw, "event:%s\ndata:%s\n\n", chunk.Event, chunk.Data.RAW)
|
|
|
+ fmt.Fprintf(hw, "data:%s\n\n", chunk.Data.RAW)
|
|
|
flusher.Flush()
|
|
|
//time.Sleep(1 * time.Millisecond)
|
|
|
}
|