java - How can we implement Observable.flatMapCompletable? -


for single can that:

init {     single.just("blah")             .flatmapcompletable { updatelocalization() } }  private fun updatelocalization(): completable {     return textsmanager.getcurrentlocalization()         .doonsuccess {             _localization =             logger.debug("updatelocalization:doonsuccess")         }         .tocompletable() } 

and method observable.flatmapcompletable(completable)? there reason why isn't implemented in rxjava? how can implement on own?

for use completable.await() in observable.onnext:

textsmanager.eventsbus.observe()         .oftype(textsmanager.event.localizationupdated::class.java)         .doonnext { updatelocalization().await() }         .subscribe() 


Comments

Popular posts from this blog

php - How to display all orders for a single product showing the most recent first? Woocommerce -

asp.net - How to correctly use QUERY_STRING in ISAPI rewrite? -

angularjs - How restrict admin panel using in backend laravel and admin panel on angular? -