(p []byte)
| 18 | } |
| 19 | |
| 20 | func (wsw *wsWrapper) Read(p []byte) (n int, err error) { |
| 21 | for { |
| 22 | msgType, reader, err := wsw.Conn.NextReader() |
| 23 | if err != nil { |
| 24 | return 0, err |
| 25 | } |
| 26 | |
| 27 | if msgType != websocket.TextMessage { |
| 28 | continue |
| 29 | } |
| 30 | |
| 31 | return reader.Read(p) |
| 32 | } |
| 33 | } |
no outgoing calls