(ctx context.Context, url string)
| 187 | } |
| 188 | |
| 189 | func newClient(ctx context.Context, url string) (*client, error) { |
| 190 | c, _, err := websocket.Dial(ctx, url+"/subscribe", nil) |
| 191 | if err != nil { |
| 192 | return nil, err |
| 193 | } |
| 194 | |
| 195 | cl := &client{ |
| 196 | url: url, |
| 197 | c: c, |
| 198 | } |
| 199 | |
| 200 | return cl, nil |
| 201 | } |
| 202 | |
| 203 | func (cl *client) publish(ctx context.Context, msg string) (err error) { |
| 204 | defer func() { |
no test coverage detected
searching dependent graphs…