From cceb1cd66cdb2b0c8594f0f3c6c7e05aeaaa1734 Mon Sep 17 00:00:00 2001
From: Benoit Marty <benoit@matrix.org>
Date: Mon, 9 Jan 2023 16:39:12 +0100
Subject: [PATCH] Add constraint on T. It has to extend `VectorViewEvents`

---
 .../main/java/im/vector/app/core/utils/SharedEvent.kt    | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/vector/src/main/java/im/vector/app/core/utils/SharedEvent.kt b/vector/src/main/java/im/vector/app/core/utils/SharedEvent.kt
index e712769c48..779270c092 100644
--- a/vector/src/main/java/im/vector/app/core/utils/SharedEvent.kt
+++ b/vector/src/main/java/im/vector/app/core/utils/SharedEvent.kt
@@ -16,16 +16,17 @@
 
 package im.vector.app.core.utils
 
+import im.vector.app.core.platform.VectorViewEvents
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.transform
 import java.util.concurrent.CopyOnWriteArraySet
 
-interface SharedEvents<out T> {
+interface SharedEvents<out T : VectorViewEvents> {
     fun stream(consumerId: String): Flow<T>
 }
 
-class EventQueue<T>(capacity: Int) : SharedEvents<T> {
+class EventQueue<T : VectorViewEvents>(capacity: Int) : SharedEvents<T> {
 
     private val innerQueue = MutableSharedFlow<OneTimeEvent<T>>(replay = capacity)
 
@@ -42,7 +43,7 @@ class EventQueue<T>(capacity: Int) : SharedEvents<T> {
  *
  * Keeps track of who has already handled its content.
  */
-private class OneTimeEvent<out T>(private val content: T) {
+private class OneTimeEvent<out T : VectorViewEvents>(private val content: T) {
 
     private val handlers = CopyOnWriteArraySet<String>()
 
@@ -53,6 +54,6 @@ private class OneTimeEvent<out T>(private val content: T) {
     fun getIfNotHandled(asker: String): T? = if (handlers.add(asker)) content else null
 }
 
-private fun <T> Flow<OneTimeEvent<T>>.filterNotHandledBy(consumerId: String): Flow<T> = transform { event ->
+private fun <T : VectorViewEvents> Flow<OneTimeEvent<T>>.filterNotHandledBy(consumerId: String): Flow<T> = transform { event ->
     event.getIfNotHandled(consumerId)?.let { emit(it) }
 }