code: func (ch *Channel) nextMsgPacket() msgPacket {
  	packet := msgPacket{}
  	packet.ChannelID = byte(ch.id)
  	packet.Bytes = ch.sending[:cmn.MinInt(maxMsgPacketPayloadSize, len(ch.sending))]
  	if len(ch.sending) <= maxMsgPacketPayloadSize {
  		packet.EOF = byte(0x01)
  		ch.sending = nil
  		atomic.AddInt32(&ch.sendQueueSize, -1) // decrement sendQueueSize
  	} else {
  		packet.EOF = byte(0x00)
  		ch.sending = ch.sending[cmn.MinInt(maxMsgPacketPayloadSize, len(ch.sending)):]
  	}
  	return packet
  }
docs: // Creates a new msgPacket to send.
  // Not goroutine-safe