WsFastHandler is a simple fasthttp.RequestHandler that implements WebSocket echo server.
(ctx *fasthttp.RequestCtx)
| 32 | // WsFastHandler is a simple fasthttp.RequestHandler that implements |
| 33 | // WebSocket echo server. |
| 34 | func WsFastHTTPHandler(ctx *fasthttp.RequestCtx) { |
| 35 | var upgrader fastwebsocket.FastHTTPUpgrader |
| 36 | err := upgrader.Upgrade(ctx, func(c *fastwebsocket.Conn) { |
| 37 | defer c.Close() |
| 38 | for { |
| 39 | mt, message, err := c.ReadMessage() |
| 40 | if err != nil { |
| 41 | break |
| 42 | } |
| 43 | err = c.WriteMessage(mt, message) |
| 44 | if err != nil { |
| 45 | break |
| 46 | } |
| 47 | } |
| 48 | }) |
| 49 | if err != nil { |
| 50 | panic(err) |
| 51 | } |
| 52 | } |
nothing calls this directly
no test coverage detected
searching dependent graphs…