|
@@ -1,12 +1,14 @@
|
|
package notification
|
|
package notification
|
|
|
|
|
|
import (
|
|
import (
|
|
|
|
+ "io"
|
|
|
|
+ "time"
|
|
|
|
+
|
|
"github.com/0xJacky/Nginx-UI/api"
|
|
"github.com/0xJacky/Nginx-UI/api"
|
|
|
|
+ "github.com/0xJacky/Nginx-UI/internal/kernel"
|
|
"github.com/0xJacky/Nginx-UI/internal/notification"
|
|
"github.com/0xJacky/Nginx-UI/internal/notification"
|
|
"github.com/0xJacky/Nginx-UI/model"
|
|
"github.com/0xJacky/Nginx-UI/model"
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/gin-gonic/gin"
|
|
- "io"
|
|
|
|
- "time"
|
|
|
|
)
|
|
)
|
|
|
|
|
|
func Live(c *gin.Context) {
|
|
func Live(c *gin.Context) {
|
|
@@ -38,6 +40,8 @@ func Live(c *gin.Context) {
|
|
case <-notify:
|
|
case <-notify:
|
|
notification.RemoveClient(c)
|
|
notification.RemoveClient(c)
|
|
return
|
|
return
|
|
|
|
+ case <-kernel.Context.Done():
|
|
|
|
+ return
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|