Method startStreamingEvents

modules/api_rest/api_rest_ws.go:105–118

(w http.ResponseWriter, r *http.Request)

}

func (mod *RestAPI) startStreamingEvents(w http.ResponseWriter, r *http.Request) {
	ws, err := mod.upgrader.Upgrade(w, r, nil)
	if err != nil {
		if _, ok := err.(websocket.HandshakeError); !ok {
			mod.Error("error while updating api.rest connection to websocket: %s", err)
		}
		return
	}

	mod.Debug("websocket streaming started for %s", r.RemoteAddr)

	go mod.streamWriter(ws, w, r)
	mod.streamReader(ws)
}