learning rxjava

gistfile1.txt

    fun loadFirstPage(): ObservableTransformer<LoadFirstPageAction, MainResult> {
        return ObservableTransformer {
            actionStream -> actionStream.flatMap { _ -> mainModel.getNews("", "10") // <-- whats wrong with you! took 1 day of my life
                .map { data -> MainResult.success(data) }
                .onErrorReturn { error -> MainResult.failure(error.message ?: "Unknown error") }
                .observeOn(AndroidSchedulers.mainThread())
                .startWith { MainResult.loading()} }
        }
    }

    fun loadNextPage(): ObservableTransformer<LoadNextPageAction, MainResult> {
        return ObservableTransformer {
            actionStream -> actionStream.flatMap {(after) -> mainModel.getNews(after, "10")
                .map { data -> MainResult.success(data) }
                .onErrorReturn { error -> MainResult.failure(error.message ?: "Unknown error") }
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .startWith { MainResult.loading()} }
        }
    }

    fun actionToResultTransformer(): ObservableTransformer<MainAction, MainResult> {
        return ObservableTransformer {
            actionStream -> actionStream.publish { shared -> Observable.merge(
                shared.ofType(LoadFirstPageAction::class.java).compose(loadFirstPage()),
                shared.ofType(LoadNextPageAction::class.java).compose(loadNextPage())) }
        }
    }