ursus
a.withLatestFrom(b.map { false }.concatWith(just(true), ::Foo) .filter { it.isBCompleted } .map { it.value }
class Foo(val value: T, val isBCompleted: Boolean)