SSE: cannot Close in callback #1047
Description
Hey, I'm using resty v3 to integrate dify.
Here is the problem I encountered: When I invoke Close in callback. The code execution will stuck.
eventSource.OnMessage(func(event any) {
data := []byte(event.(*resty.Event).Data)
var chunk struct {
Event string `json:"event"`
}
_ = json.Unmarshal(data, &chunk)
if chunk.Event == "message_end" {
eventSource.Close()
}
fn(chunk.Event, data)
}, nil)