These are chat archives for ReactiveX/RxJava

Mar 2017
Mar 27 2017 04:37

hi guys,
I have methods:

Observable<List<Product>> getProducts()
Observable<List<Category>> getCategories()

I want to implement:

Observable<List<Product>> getEnrichedProducts() {
    // call getProducts
    // call getCategories
    // 1. enrich every single product with category object then return list of enriched product
    // 2. If getCategories throws exception just return original products returned from getProducts