sse
sse copied to clipboard
feat: Encode function can optimize byte array handling
In scenarios where byte array JSON messages are forwarded (e.g., from MQ), the previous approach required unmarshalling into an object before encoding for SSE.
The updated logic allows []byte to be passed directly, simplifying message forwarding and reducing unnecessary conversions.
// before
byteData := messageFromMQ()
data := make(map[string]any)
json.Unmarshal(byteData, &data)
sse.Encode(new(bytes.Buffer), sse.Event{
Data: data,
})
// after
byteData := messageFromMQ()
sse.Encode(new(bytes.Buffer), sse.Event{
Data: byteData,
})