Mark
09/14/2020, 10:44 AMFlow.distinctBy()
? For example:
fun <T, K> Flow<T>.distinctBy(selector: (T) -> K) = flow {
val keys = mutableSetOf<K>()
collect { item ->
if (keys.add(selector(item))) {
emit(item)
}
}
}