in src/datachannel/streaming.go [776:793]
func (dataChannel DataChannel) HandleChannelClosedMessage(log log.T, stopHandler Stop, sessionId string, outputMessage message.ClientMessage) {
var (
channelClosedMessage message.ChannelClosed
err error
)
if channelClosedMessage, err = outputMessage.DeserializeChannelClosedMessage(log); err != nil {
log.Errorf("Cannot deserialize payload to ChannelClosedMessage: %v.", err)
}
log.Infof("Exiting session with sessionId: %s with output: %s", sessionId, channelClosedMessage.Output)
if channelClosedMessage.Output == "" {
fmt.Fprintf(os.Stdout, "\n\nExiting session with sessionId: %s.\n\n", sessionId)
} else {
fmt.Fprintf(os.Stdout, "\n\nSessionId: %s : %s\n\n", sessionId, channelClosedMessage.Output)
}
stopHandler()
}