Kotlin Flow Dedup Extension Functions

FlowDedup.kt

import kotlinx.coroutines.flow.flow

inline fun <T> Flow<T>.dedupBy(crossinline predicate: suspend (T, T) -> Boolean): Flow<T> =
    let { source ->
        var prevValue: T? = null
        flow {
            source.collect { value ->
                if (prevValue == null || !predicate(prevValue!!, value)) {
                    prevValue = value
                    emit(value)
                }
            }
        }
    }

fun <T> Flow<T>.dedup(): Flow<T> = dedupBy { a, b -> a == b }