()
| 348 | } |
| 349 | |
| 350 | func (w *wsResponseWriter) end() error { |
| 351 | w.mu.Lock() |
| 352 | defer w.mu.Unlock() |
| 353 | if w.completed { |
| 354 | return nil |
| 355 | } |
| 356 | w.completed = true |
| 357 | return w.sink.end() |
| 358 | } |
| 359 | |
| 360 | func (w *wsResponseWriter) fail(message string, code string) error { |
| 361 | w.mu.Lock() |