in wrappers.go [149:165]
func (w *ioWrapper) Write(data []byte) (n int, err error) {
n = len(data)
w.mu.Lock()
mt := w.messageType
w.mu.Unlock()
if mt != websocket.BinaryMessage {
utf8, err := w.encoder.String(string(data))
if err != nil {
return 0, err
}
data = []byte(utf8)
}
err = w.WriteMessage(mt, data)
return n, err
}