in src/datachannel/streaming.go [382:401]
func (dataChannel *DataChannel) SendAcknowledgeMessage(log log.T, streamDataMessage message.ClientMessage) (err error) {
dataStreamAcknowledgeContent := message.AcknowledgeContent{
MessageType: streamDataMessage.MessageType,
MessageId: streamDataMessage.MessageId.String(),
SequenceNumber: streamDataMessage.SequenceNumber,
IsSequentialMessage: true,
}
var msg []byte
if msg, err = message.SerializeClientMessageWithAcknowledgeContent(log, dataStreamAcknowledgeContent); err != nil {
log.Errorf("Cannot serialize Acknowledge message err: %v", err)
return
}
if err = SendMessageCall(log, dataChannel, msg, websocket.BinaryMessage); err != nil {
log.Errorf("Error sending acknowledge message %v", err)
return
}
return
}