davidliu

Fix message handling in example

... ... @@ -111,8 +111,6 @@ class CallViewModel(
private val mutablePermissionAllowed = MutableStateFlow(true)
val permissionAllowed = mutablePermissionAllowed.hide()
var messagesReceived = 0
init {
viewModelScope.launch {
// Collect any errors.
... ... @@ -139,8 +137,8 @@ class CallViewModel(
is RoomEvent.FailedToConnect -> mutableError.value = it.error
is RoomEvent.DataReceived -> {
val identity = it.participant?.identity ?: "server"
messagesReceived++
Timber.e { "message received from $identity, count $messagesReceived" }
val message = it.data.toString(Charsets.UTF_8)
mutableDataReceived.emit("$identity: $message")
}
else -> {
... ...