web/notify.moe
Code Issues Pull Requests Activity

Added SSE code comments

Browse Source
This commit is contained in:
Eduard Urbach 2019-03-31 16:46:44 +09:00
parent 49653bfb38
commit 0ecaec29da
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pages/sse/sse.go
View File

@ -32,6 +32,7 @@ func Events(ctx *aero.Context) string {
defer fmt.Println(user.Nick, "disconnected, stop sending events") defer fmt.Println(user.Nick, "disconnected, stop sending events")
defer user.RemoveEventStream(stream) defer user.RemoveEventStream(stream)
// Send the ETag for the scripts
stream.Events <- &aero.Event{ stream.Events <- &aero.Event{
Name: "etag", Name: "etag",
Data: struct { Data: struct {
@ -43,6 +44,7 @@ func Events(ctx *aero.Context) string {
}, },
} }
// Send the ETag for the styles
stream.Events <- &aero.Event{ stream.Events <- &aero.Event{
Name: "etag", Name: "etag",
Data: struct { Data: struct {
@ -54,6 +56,7 @@ func Events(ctx *aero.Context) string {
}, },
} }
// Wait until the user closes the tab or disconnects
<-stream.Closed <-stream.Closed
}() }()