pkg/sse/server.go

@@ -14,7 +14,7 @@ var _ Server = (*event)(nil)
 type Server interface {
 	GinHandle(ctx *gin.Context, user any)
 	HandlerFunc() mux.HandlerFunc
-	Push(user, name, msg string) bool
+	Push(user any, name, msg string) bool
 	Broadcast(name, msg string)
 }
 
@@ -104,7 +104,7 @@ func (stream *event) HandlerFunc() mux.HandlerFunc {
 	}
 }
 
-func (stream *event) Push(user, name, msg string) bool {
+func (stream *event) Push(user any, name, msg string) bool {
 	value, ok := stream.SessionList.Load(user)
 	if ok {
 		val := value.(chan msgChan)