override fun onDataMessageReceived()

in amazon-chime-sdk/src/main/java/com/amazonaws/services/chime/sdk/meetings/internal/video/DefaultVideoClientObserver.kt [243:263]

• 20 lines of code
• 4 McCabe index (conditional complexity)

    override fun onDataMessageReceived(dataMessages: Array<mediaDataMessage>?) {
        if (dataMessages == null) return

        logger.debug(TAG, "onDataMessageReceived with size: ${dataMessages.size}")
        for (dataMessage in dataMessages) {
            if (!dataMessageObserversByTopic.containsKey(dataMessage.topic)) continue
            val sdkDataMessage = DataMessage(
                dataMessage.timestampMs,
                dataMessage.topic,
                dataMessage.data,
                dataMessage.senderAttendeeId,
                dataMessage.senderExternalUserId,
                dataMessage.throttled
            )
            dataMessageObserversByTopic[dataMessage.topic]?.let { observers ->
                ObserverUtils.notifyObserverOnMainThread(observers) {
                    it.onDataMessageReceived(sdkDataMessage)
                }
            }
        }
    }