Is there a proper way to filter an Observable stre...

# reaktive

[Luigi Scarminio]

Is there a proper way to filter an Observable stream and log the ones that have been left out?

[Arkadii Ivanov]

Maybe

observableOf(1, 2, 3, 4, 5)
            .filter { 
                (it % 2 == 0).also { 
                    if (!it) {
                        println(it)
                    }
                }
            }

[Arkadii Ivanov]

Or define the following operator:

inline fun <T> Observable<T>.filter(crossinline predicate: (T) -> Boolean, crossinline onFiltered: (T) -> Unit): Observable<T> =
        filter { item ->
            predicate(item).also { 
                if (!it) {
                    onFiltered(item)
                }
            }
        }

[Luigi Scarminio]

I liked the operator's solution. Thanks!