connection.go
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
}
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
}
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 }
// Creates a new msgPacket to send.
// Not goroutine-safe
Creates a new msgPacket to send . Not goroutine - safe