diff --git a/pkg/server/converge/websessions.go b/pkg/server/converge/websessions.go index 709a543..745de7a 100644 --- a/pkg/server/converge/websessions.go +++ b/pkg/server/converge/websessions.go @@ -71,8 +71,6 @@ func GetUserLocation(r *http.Request) (*time.Location, error) { } func (session *WebSession) WriteNotifications(location *time.Location) { - timer := time.NewTicker(10 * time.Second) - defer timer.Stop() for { select { case notification, ok := <-session.notifications: @@ -85,18 +83,6 @@ func (session *WebSession) WriteNotifications(location *time.Location) { log.Printf("WS connection closed: %v", err) return } - case <-timer.C: - // Read of 0 bytes seems to be more reliable than write - //_, err := session.conn.Write(make([]byte, 0, 0)) - //if err != nil { - // log.Printf("WS connection closed: %v", err) - // return - //} - _, err := session.conn.Read(make([]byte, 0, 0)) - if err != nil { - log.Printf("WS connection closed: %v", err) - return - } } } }