Денис Загаевский

data class Data(var x : Int)

Observable.just(1, 1, 2, 2)
    .doOnNext { print("I'm $it") }
    .map(::Data)
    . distinctUntilChanged()
    .map{
       it.apply{ x++ }
    }
    .doOnNext { print("Now I'm $it") }
    .subscribe()

sealed class Result {
    data class Success(result: String): Result()
    data class Error(exception: Exception): Result()
}

getItems()
.flatMapObservable { items ->
    Observable.fromIterable(items).switchMap { "прозвонить ссылку, что бы это не значило" }
}.toList()

request1.flatMap{ mediaDetail ->
   request2(mediaDetail.id).map{
       mediaDetail.copy(assets=it.item)
   }
}. subscribe

Observable.defer { AsyncMethod(param1,param2,ApiKeyStore.CurrentKey) } 
.doOnError{
    ApiKeyStore.getNextApiKey()
}
.retry(ApiKeyStore.attemptsNumber)

.onErrorReturnItem(mutableListOf(Video("ErrorId")))

Observable.fromIterable(holders) //Observable<Holder>
    .concatMap(holder -> Observable.fromIterable(holder.images) //Observable<Image>
        .concatMap(image -> uploadImage(image)) //Observable<Image>
        .toList() //Observable<List<Image>>
        .map(images -> holder)) //Observable<Holder>
    .toList() //Observable<List<Holder>>
    .switchMap(holders -> uploadHolders(holders))
    .subscribe();

.switchMap(article -> Observable.zip(
    getUser(...).first(), 
    getCategory(...).first(),
     (user, category) -> { return new ArticleItem(...); })
.toList()
.subscribe(listOfArticleItems -> ...);