5 Commits

Author SHA1 Message Date
a0b561237a Merge pull request 'dev' (#14) from dev into main
Reviewed-on: #14
2024-09-07 15:55:29 +08:00
ad1e06229f [🚀] message 2024-09-07 15:55:14 +08:00
e99a8dbcd6 [🚀] message 2024-09-07 15:53:46 +08:00
d3513ae4fa Merge pull request '[🚀] Ticker' (#13) from dev into main
Reviewed-on: #13
2024-09-07 15:44:39 +08:00
99264c6715 [🚀] Ticker 2024-09-07 15:44:13 +08:00

View File

@ -7,6 +7,7 @@ import (
"net/http"
"sync"
"sync/atomic"
"time"
)
var _ Server = (*event)(nil)
@ -31,9 +32,8 @@ type msgChan struct {
type event struct {
SessionList sync.Map
Count atomic.Int32
Register chan clientChan
Unregister chan any
Register chan clientChan
Unregister chan any
}
func NewServer() Server {
@ -123,6 +123,10 @@ func (stream *event) GinHandlerFunc(auth func(c *gin.Context) (string, error)) g
c.Writer.Header().Set("Connection", "keep-alive")
c.Writer.Header().Set("Transfer-Encoding", "chunked")
time.AfterFunc(time.Second, func() {
e <- msgChan{Name: "message", Message: "success"}
})
c.Stream(func(w io.Writer) bool {
if msg, ok := <-e; ok {
c.SSEvent(msg.Name, msg.Message)