DistinctUntilChanged

.kt

fun <T> Flow<T>.distinctUntilChanged(comparator: (T, T) -> Boolean): Flow<T> = flow {
    var previous: T? = null
    var isFirst = true

    collect { value ->
        if (isFirst || !comparator(previous!!, value)) {
            emit(value)
            previous = value
            isFirst = false
        }
    }
}