func()

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]
	}
}