()
| 74 | } |
| 75 | } |
| 76 | func (w *WsConnection) send() { |
| 77 | for { |
| 78 | select { |
| 79 | case message := <-w.writeChan: |
| 80 | writer, err := w.ws.NextWriter(websocket.TextMessage) |
| 81 | if err != nil { |
| 82 | w.close() |
| 83 | return |
| 84 | } |
| 85 | _, _ = writer.Write(message) |
| 86 | _ = writer.Close() |
| 87 | case <-w.closeChan: |
| 88 | return |
| 89 | } |
| 90 | } |
| 91 | } |
| 92 | |
| 93 | func (w *WsConnection) ReadMsg() (message []byte, err error) { |
| 94 | select { |
no test coverage detected