Как извлечь, работать и вернуть информацию из Observable Java RX 1.2 и Kotlin

Question

Я работаю с цепочкой наблюдателей.Я подписываюсь на метод вызова внутреннего вызова, как:

 Observable.just(dCSService.get(dCSServiceContext))
                .map { "hello " + it }
                .subscribe { println(it)}

В обоих случаях, внутри карты и подписки, я получаю Observable, любые идеи о том, как я могу получить доступ к объектамиз наблюдаемого?Эти объекты имеют тип:

Single<List<DCSItem?>>

Заранее спасибо!

Answer 1

Как я понимаю, если внутри карты вы получаете один, вы используете неправильный оператор.вам не нужно использовать Observable.just для запуска потока, потому что у вас уже есть поток, поэтому вы можете сделать это следующим образом

 dCSService.get(dCSServiceContext)
            .map { "hello " + it }
            .subscribe { println(it)}

, если вы хотите, чтобы список генерировался один за другим, вы можете использовать

 dCSService.get(dCSServiceContext)
            .flatMapIterable(item -> item)
            .map { "hello " + it }
            .subscribe { println(it)}