()
| 230 | } |
| 231 | |
| 232 | func (cl *client) nextMessage() (string, error) { |
| 233 | typ, b, err := cl.c.Read(context.Background()) |
| 234 | if err != nil { |
| 235 | return "", err |
| 236 | } |
| 237 | |
| 238 | if typ != websocket.MessageText { |
| 239 | cl.c.Close(websocket.StatusUnsupportedData, "expected text message") |
| 240 | return "", fmt.Errorf("expected text message but got %v", typ) |
| 241 | } |
| 242 | return string(b), nil |
| 243 | } |
| 244 | |
| 245 | func (cl *client) Close() error { |
| 246 | return cl.c.Close(websocket.StatusNormalClosure, "") |
no test coverage detected