Task-RxJava.kt

 bool1.withLatestFrom(bool2, BiFunction<Boolean, Boolean, Boolean> { t1, t2 -> t1 && t2 })
            .doAfterNext { voidFun() }.onErrorReturnItem(false)
            .switchMap { item -> return@switchMap if (item) {
                    Flowable.create({ sub ->
                        num.filter { number -> number % 2 == 0 }.take(1)
                            .subscribeOn(Schedulers.computation())
                            .map { (1.0 / it).toString() }.subscribe(
                                {
                                    sub.onNext(it)
                                }, { error ->
                                    Log.e("TAG", error.localizedMessage)
                                })
                    }, BackpressureStrategy.MISSING)
                } else Flowable.just("") }
            .observeOn(Schedulers.newThread())
            .doOnNext {
                println("Ура ${Thread.currentThread().name}")
            }
            .subscribeOn(Schedulers.io())
            .subscribe { }