diff --git a/app/web_conn.go b/app/web_conn.go index 1a7da373e2..c4919a6e9b 100644 --- a/app/web_conn.go +++ b/app/web_conn.go @@ -232,9 +232,7 @@ func (wc *WebConn) writePump() { } if wc.App.Metrics() != nil { - wc.App.Srv().Go(func() { - wc.App.Metrics().IncrementWebSocketBroadcast(msg.EventType()) - }) + wc.App.Metrics().IncrementWebSocketBroadcast(msg.EventType()) } }