Как мы можем реализовать Observable.flatMapCompletable?

Для Single мы можем сделать так:

 init { Single.just("blah") .flatMapCompletable { updateLocalization() } } private fun updateLocalization(): Completable { return textsManager.getCurrentLocalization() .doOnSuccess { _localization = it logger.debug("updateLocalization:doOnSuccess") } .toCompletable() } 

А как насчет метода, например Observable.flatMapCompletable(completable) ? Есть ли причина, почему она не реализована в rxjava? Как я могу реализовать это самостоятельно?

На данный момент я использую Completable.await() в Observable.onNext :

 textsManager.eventsBus.observe() .ofType(TextsManager.Event.LocalizationUpdated::class.java) .doOnNext { updateLocalization().await() } .subscribe()