From dc4627f5030c2910f922934cab6ed93416bdc692 Mon Sep 17 00:00:00 2001 From: Supan Adit Pratama Date: Sat, 4 Jan 2020 08:02:45 +0700 Subject: [PATCH] Fix SSE for Location Stream --- system/router.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/system/router.go b/system/router.go index cedd63f..2e51121 100644 --- a/system/router.go +++ b/system/router.go @@ -61,11 +61,12 @@ func Router(r *gin.Engine, client *redis.Client) { }) r.GET("/point/get/stream", func(c *gin.Context) { - w := c.Writer - t := c.DefaultQuery("type", "user") - data, _ := tile38.FromScan(client, t) - - _ = sse.Encode(w, sse.Event{ + writer := c.Writer + writer.Header().Set("Content-Type", "text/event-stream") + writer.Header().Set("Cache-Control", "no-cache") + writer.Header().Set("Connection", "keep-alive") + data, _ := tile38.FromScan(client, "user") + _ = sse.Encode(writer, sse.Event{ Event: "message", Data: data, })