sse

type Config struct {
	BufferSize int    `json:"buffer_size"` // 消息通道缓冲区大小，默认为1
	EventName  string `json:"event_name"`  // SSE事件名称，默认为"message"
}

type Handler interface {
	// Stream 启动SSE流式推送
	Stream(ctx *gin.Context, producer Producer, config ...*Config) error
	// StreamWithContext 使用自定义上下文启动SSE流式推送
	StreamWithContext(ctx context.Context, writer io.Writer, producer Producer, config ...*Config) error
}

type Producer func(ctx context.Context, msgChan chan<- interface{})