val activeFlowId = AtomicInteger()
    val sharedFlow = eventChannel.consumeAsFlow().shareIn(scope, SharingStarted.Eagerly, 1024)

    fun getFlow(minIndex: Int = 0): Flow<ChatEvent> {
        val flowId = activeFlowId.incrementAndGet()

        return sharedFlow
            .filter { it.index >= minIndex }
            .takeWhile { flowId == activeFlowId.get() }
            .cancellable()
            .buffer(16, BufferOverflow.DROP_OLDEST)
    }

id

id

DROP_OLDEST

class HandlerChatSession
private constructor(
    val chatEnded: AtomicBoolean,
    val eventFlow: MutableSharedFlow<ChatEvent>,
    private val eventIndex: AtomicInteger,
    private val currentFlowListenerContext: MutableStateFlow<Job?>
) {

    fun getFlow(minIndex: Int = 0): Flow<ChatEvent> {
        currentFlowListenerContext.value?.cancel("New subscription received. Cancelling current.")
        return eventFlow
            .asSharedFlow()
            .onStart { currentFlowListenerContext.value = currentCoroutineContext().job }
            .takeWhile { !chatEnded.get() }
            .filter { it.index >= minIndex }
    }