| 1136 | } |
| 1137 | |
| 1138 | func (c *RTCClient) handleDataMessage(kind livekit.DataPacket_Kind, data []byte) { |
| 1139 | dp := &livekit.DataPacket{} |
| 1140 | err := proto.Unmarshal(data, dp) |
| 1141 | if err != nil { |
| 1142 | return |
| 1143 | } |
| 1144 | dp.Kind = kind |
| 1145 | if val, ok := dp.Value.(*livekit.DataPacket_User); ok { |
| 1146 | if c.OnDataReceived != nil { |
| 1147 | c.OnDataReceived(val.User.Payload, val.User.ParticipantSid) |
| 1148 | } |
| 1149 | } |
| 1150 | } |
| 1151 | |
| 1152 | func (c *RTCClient) handleDataMessageUnlabeled(data []byte) { |
| 1153 | if c.OnDataUnlabeledReceived != nil { |