rxjava2's Introduction

rxjava2

O Projeto utiliza como serviço externo a api The Star Wars API, https://swapi.co/documentation#schema Libs utilizadas: Retrofit - para tratar o serviço da Api, RxJava - para fazer as chamadas de serviços da Api, Mockito - para testes, Kotlin.

Para os testes é utlizado a classe Rule(RxImmediateSchedulerRule), para transformar as Threads de io, computation e newThread em Trampolim assim evitando o problema de chamadas simultaneas.

Para utlizar em projetos Android adicione a lib:

implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'

E quando for atualizar a Thread de ui, será utilizado o Schedulers:

    AndroidSchedulers.mainThread()

Exemplo:

    override fun getPeople(idPeople:Int): Observable<People> {
        return apiService.getPeople(idPeople).
            subscribeOn(Schedulers.io()).
            observeOn(AndroidSchedulers.mainThread())
    }

E para testes no Android a classe RxImmediateSchedulerRule deve ser modificada:

    class RxImmediateSchedulerRule : TestRule {

    override fun apply(base: Statement, d: Description): Statement {
        return object : Statement() {
            @Throws(Throwable::class)
            override fun evaluate() {
                RxJavaPlugins.setIoSchedulerHandler { Schedulers.trampoline() }
                RxJavaPlugins.setComputationSchedulerHandler { Schedulers.trampoline() }
                RxJavaPlugins.setNewThreadSchedulerHandler { Schedulers.trampoline() }
                RxAndroidPlugins.setInitMainThreadSchedulerHandler { Schedulers.trampoline() }

                try {
                    base.evaluate()
                } finally {
                    RxJavaPlugins.reset()
                    RxAndroidPlugins.reset()
                }
            }
        }
    }

Recommend Projects