usecaseflatmaprx.kt

class SearchShows @Inject
constructor(private val showRepository: ShowRepository) : UseCase() {
    var query: String? = null

    override fun buildUseCaseObservable(): Single<List<ShowResponse>> {
        return showRepository.searchShow(query).flatMapPublisher { Flowable.fromIterable(it) }
                .flatMapSingle({ showInfo:ShowInfo ->
                    showRepository.showRating(showInfo.show.ids.trakt)
                            .subscribeOn(Schedulers.io())
                            .map { rating ->
                                ShowResponse(showInfo.show.title, rating
                                        .rating)
                            }
                },false, 4).toList()
    }
}