RxCompose

compose.kt

override fun doSomeWork() {
        val d = Observable.create(ObservableOnSubscribe<String> { e ->
            for (i in 0 until 10) {
                val number = Math.pow(Random().nextInt(100).toDouble(), Random().nextInt(100).toDouble())
                e.onNext(number.toString())
            }
            e.onComplete()
        }).compose(loading { isShow ->
            if (isShow) {
                view.showLoading()
            } else {
                view.hideLoading()
            }
        }).compose(before { before()
        }).compose(after { after()
        }).compose(observableIo())
                .subscribe { number ->
                    view.showCompleteWork(number)
                }
        disposable.add(d)
    }