Filter duplicated events in live voice broadcasts

Florian Renaud · Florian Renaud · commit 20abef26b0a6 · 2022-11-01T17:59:59.000+01:00
diff --git a/vector/src/main/java/im/vector/app/features/voicebroadcast/listening/usecase/GetLiveVoiceBroadcastChunksUseCase.kt b/vector/src/main/java/im/vector/app/features/voicebroadcast/listening/usecase/GetLiveVoiceBroadcastChunksUseCase.kt
@@ -29,6 +29,7 @@ import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.flow.emptyFlow
 import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.runningReduce
 import org.matrix.android.sdk.api.session.events.model.RelationType
 import org.matrix.android.sdk.api.session.room.model.message.MessageAudioEvent
@@ -106,6 +107,7 @@ class GetLiveVoiceBroadcastChunksUseCase @Inject constructor(
                 }
             }
                     .runningReduce { accumulator: List<MessageAudioEvent>, value: List<MessageAudioEvent> -> accumulator.plus(value) }
+                    .map { events -> events.distinctBy { it.sequence } }
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -29,6 +29,7 @@ import kotlinx.coroutines.flow.Flow`
`29`	`29`	`import kotlinx.coroutines.flow.callbackFlow`
`30`	`30`	`import kotlinx.coroutines.flow.emptyFlow`
`31`	`31`	`import kotlinx.coroutines.flow.flowOf`
	`32`	`+import kotlinx.coroutines.flow.map`
`32`	`33`	`import kotlinx.coroutines.flow.runningReduce`
`33`	`34`	`import org.matrix.android.sdk.api.session.events.model.RelationType`
`34`	`35`	`import org.matrix.android.sdk.api.session.room.model.message.MessageAudioEvent`
`@@ -106,6 +107,7 @@ class GetLiveVoiceBroadcastChunksUseCase @Inject constructor(`
`106`	`107`	`}`
`107`	`108`	`}`
`108`	`109`	`.runningReduce { accumulator: List<MessageAudioEvent>, value: List<MessageAudioEvent> -> accumulator.plus(value) }`
	`110`	`+ .map { events -> events.distinctBy { it.sequence } }`
`109`	`111`	`}`
`110`	`112`	`}`
`111`	`113`