in server.go [120:138]
func (s *connection) loopWrite() {
buffers := net.Buffers{}
for {
s.toSendCond.L.Lock()
for len(s.toSend) == 0 && !s.isClosed {
s.toSendCond.Wait()
}
if s.isClosed {
s.toSendCond.L.Unlock()
return
}
buffers = append(buffers, s.toSend...)
s.toSend = s.toSend[:0]
s.toSendCond.L.Unlock()
buffers.WriteTo(s.cnx)
buffers = buffers[:0]
}
}