natpryce
fun <T> Observable<T?>.dropNulls(): Observable<T> = flatMap { it?.let{single(it)}?:empty() }