首页 / JAVA / 如何在单元测试中处理模拟的RxJava2可观察抛出异常

如何在单元测试中处理模拟的RxJava2可观察抛出异常

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了如何在单元测试中处理模拟的RxJava2可观察抛出异常，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7461字，纯文字阅读大概需要11分钟。

内容图文

过去几周我一直在使用MVP在Android中在Kotlin做TDD.事情进展顺利.

我使用Mockito来模拟类,但我似乎无法克服如何实现我想要运行的测试之一.

以下是我的测试：

>调用api,接收数据列表,然后显示列表. loadAllPlacesTest()
>调用api,接收空数据,然后显示列表. loadEmptyPlacesTest()
>调用api,路上会发生一些异常,然后显示错误信息. loadExceptionPlacesTest()

我成功地测试了#1和#2.问题在于#3,我不确定如何在代码中进行测试.

RestApiInterface.kt

interface RestApiInterface {

@GET(RestApiManager.PLACES_URL)
fun getPlacesPagedObservable(
        @Header("header_access_token") accessToken: String?,
        @Query("page") page: Int?
): Observable<PlacesWrapper>
}

RestApiManager.kt
实现接口的manager类如下所示：

open class RestApiManager: RestApiInterface{
var api: RestApiInterface
    internal set
internal var retrofit: Retrofit
init {
    val logging = HttpLoggingInterceptor()
    // set your desired log level
    logging.setLevel(HttpLoggingInterceptor.Level.BODY)

    val client = okhttp3.OkHttpClient().newBuilder()
            .readTimeout(60, TimeUnit.SECONDS)
            .connectTimeout(60, TimeUnit.SECONDS)
            .addInterceptor(LoggingInterceptor())  
            .build()


    retrofit = Retrofit.Builder()
            .baseUrl(BASE_URL)
            .client(client)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())//very important for RXJAVA and retrofit
            .build()
    api = retrofit.create(RestApiInterface::class.java)
}
override fun getPlacesPagedObservable(accessToken: String?, page: Int?): Observable<PlacesWrapper> {
    //return throw Exception("sorry2")
    return api.getPlacesPagedObservable(
            accessToken,
            page)
}
}

}

这是我的单元测试：

class PlacesPresenterImplTest : AndroidTest(){

lateinit var presenter:PlacesPresenterImpl
lateinit var view:PlacesView
lateinit var apiManager:RestApiManager
//lateinit var apiManager:RestApiManager

val EXCEPTION_MESSAGE1 = "SORRY"

val MANY_PLACES = Arrays.asList(PlaceItem(), PlaceItem());
var EXCEPTION_PLACES = Arrays.asList(PlaceItem(), PlaceItem());


val manyPlacesWrapper = PlacesWrapper(MANY_PLACES)
var exceptionPlacesWrapper = PlacesWrapper(EXCEPTION_PLACES)
val emptyPlacesWrapper = PlacesWrapper(Collections.emptyList())

@After
fun clear(){
    RxJavaPlugins.reset()
}
@Before
fun init(){
    //MOCKS THE subscribeOn(Schedulers.io()) to use the same thread the test is being run on
    //Schedulers.trampoline() runs the test in the same thread used by the test
    RxJavaPlugins.setIoSchedulerHandler { t -> Schedulers.trampoline() }

    view = Mockito.mock<PlacesView>(PlacesView::class.java)
    apiManager = Mockito.mock(RestApiManager::class.java)
    presenter = PlacesPresenterImpl(view,context(), Bundle(), Schedulers.trampoline())
    presenter.apiManager = apiManager

    //exceptionPlacesWrapper = throw Exception(EXCEPTION_MESSAGE1);
}


@Test
fun loadAllPlacesTest() {
    Mockito.`when`(apiManager.getPlacesPagedObservable(Mockito.anyString(), Mockito.anyInt())).thenReturn(Observable.just(manyPlacesWrapper))

    presenter.__populate()
    Mockito.verify(view, Mockito.atLeastOnce()).__showLoading()
    Mockito.verify(view, Mockito.atLeastOnce())._showList()
    Mockito.verify(view).__hideLoading()
    Mockito.verify(view).__showFullScreenMessage(Mockito.anyString())
}

@Test
fun loadEmptyPlacesTest() {

    Mockito.`when`(apiManager.getPlacesPagedObservable(Mockito.anyString(), Mockito.anyInt())).thenReturn(Observable.just(emptyPlacesWrapper))
    presenter.__populate()
    Mockito.verify(view, Mockito.atLeastOnce()).__showLoading()
    Mockito.verify(view, Mockito.atLeastOnce())._showList()
    Mockito.verify(view).__hideLoading()
    Mockito.verify(view).__showFullScreenMessage(Mockito.anyString())
}

@Test
fun loadExceptionPlacesTest() {
    Mockito.`when`(apiManager.getPlacesPagedObservable(Mockito.anyString(), Mockito.anyInt())).thenThrow(Exception(EXCEPTION_MESSAGE1))
    presenter.__populate()
    Mockito.verify(view, Mockito.atLeastOnce()).__showLoading()
    Mockito.verify(view, Mockito.never())._showList()
    Mockito.verify(view).__hideLoading()
    Mockito.verify(view).__showFullScreenMessage(EXCEPTION_MESSAGE1)
}
}

PlacesPresenterImpl.kt
这是主持人.

   class PlacesPresenterImpl
constructor(var view: PlacesView, var context: Context, var savedInstanceState:Bundle?, var mainThread: Scheduler)
: BasePresenter(), BasePresenterInterface, PlacesPresenterInterface {

lateinit var apiManager:RestApiInterface
var placeListRequest: Disposable? = null


override fun __firstInit() {
    apiManager = RestApiManager()
}

override fun __init(context: Context, savedInstanceState: Bundle, view: BaseView?) {
    this.view = view as PlacesView
    if (__isFirstTimeLoad())
        __firstInit()
}


override fun __destroy() {
    placeListRequest?.dispose()
}

override fun __populate() {
    _callPlacesApi()
}


override fun _callPlacesApi() {
    view.__showLoading()
    apiManager.getPlacesPagedObservable("", 0)
            .subscribeOn(Schedulers.io())
            .observeOn(mainThread)
            .subscribe (object : DisposableObserver<PlacesWrapper>() {
                override fun onNext(placesWrapper: PlacesWrapper) {
                    placesWrapper?.let {
                        val size = placesWrapper.place?.size
                        view.__hideLoading()
                        view._showList()
                        System.out.println("Great I found " + size + " records of places.")
                        view.__showFullScreenMessage("Great I found " + size + " records of places.")
                    }
                    System.out.println("onNext()")
                }

                override fun one rror(e: Throwable) {
                    System.out.println("onError()")
                    //e.printStackTrace()
                    view.__hideLoading()
                    if (ExceptionsUtil.isNoNetworkException(e)){
                        view.__showFullScreenMessage("So sad, can not connect to network to get place list.")
                    }else{
                        view.__showFullScreenMessage("Oops, something went wrong. ["+e.localizedMessage+"]")
                    }

                    this.dispose()
                }

                override fun onComplete() {
                    this.dispose()
                    //System.out.printf("onComplete()")
                }
            })


}

private fun _getEventCompletionObserver(): DisposableObserver<String> {
    return object : DisposableObserver<String>() {
        override fun onNext(taskType: String) {
            //_log(String.format("onNext %s task", taskType))
        }

        override fun one rror(e: Throwable) {
            //_log(String.format("Dang a task timeout"))
            //Timber.e(e, "Timeout Demo exception")
        }

        override fun onComplete() {
            //_log(String.format("task was completed"))
        }
    }
}}

loadExceptionPlacesTest()的问题/问题

>我不确定为什么代码不会转到Presenter的onError().
如果我错了,请纠正我,但这就是我的想法：

>
a – `apiManager.getPlacesPagedObservable(“”,0)`observable本身抛出一个异常,这就是为什么`.subscribe()`不能发生/继续,并且观察者的方法不会被调用,

>
b – 当observable中的操作遇到类似JSONException的异常时,它只会转到onError()

>对于loadExceptionPlacesTest(),我认为上面的1b是让演示者的onError()调用并使测试通过的方法.它是否正确？如果是在测试中如何做到这一点.如果不是,你们可以指出我错过了什么或做错了吗？

解决方法:

我将把它留在这里以供将来参考,并且能够详细说明,即使我已在评论中回答.

您要完成的是将流放入onError流中.不幸的是,通过嘲笑它：

Mockito.`when`(apiManager.getPlacesPagedObservable(
                   Mockito.anyString(), Mockito.anyInt()))
                           .thenThrow(Exception(EXCEPTION_MESSAGE1))

你实际上是在告诉Mockito以一种只调用apiManager.getPlacesPagedObservable(anystring,anystring)的方式来设置你的模拟应该抛出一个异常.

确实,在Rx流中抛出异常将导致整个流停止并以onError方法结束.但是,这正是您正在使用的方法的问题.抛出异常时,您不在流中.

相反,你要做的是告诉Mockito,一旦你调用apiManager.getPlacesPagedObservable(anystring,anystring),你想要返回一个最终会出现在onError中的流.使用Observable.error()可以很容易地实现这一点：

Mockito.`when`(apiManager.getPlacesPagedObservable(
               Mockito.a??nyString(), Mockito.anyInt()))
                    .thenReturn(Observable.error(
                                Exception(EXCEPTION_MESSAGE1)))

(你可能需要在这里添加一些类型信息Observable.error(),你可能还需要使用别的东西而不是可观察的 – 单一的,可完成的等等)

上面的模拟将告诉Mockito设置你的模拟返回一个可以在订阅时出错的observable.这将反过来将您的订阅者直接置于具有指定异常的onError流中.

内容总结

以上是互联网集市为您收集整理的如何在单元测试中处理模拟的RxJava2可观察抛出异常全部内容，希望文章能够帮你解决如何在单元测试中处理模拟的RxJava2可观察抛出异常所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/805418.html

来源：【匿名】

【上一篇】Java: Set String List 互转【下一篇】JAVA/JSP学习系列之五

更多 ►

【如何在单元测试中处理模拟的RxJava2可观察抛出异常】教程文章相关的互联网学习教程文章

Rxjava2 可连接的Observable（ConnectableObservable）操作详解及实例【代码】【图】

目录简要：1. ConnectableObservable2. Publish3. Connect4. RefCount5. Share6. Replay小结简要：需求了解：Rxjava中的普通的 Observable 在观察者订阅的时候就会发射数据，但是有的时候我们想自己控制数据的发射，比如在有指定的观察者或者全部的观察者订阅后开始发射数据，这个时候我们就要要用到Rxjava中的可连接的Observable来完成这个需求。这一节主要介绍 ConnectableObservable 和它的子类以及它们的操作符：ConnectableOb...

Rxjava2入门教程三：Operators操作符【代码】【图】

Operators操作符操作符（Operators）：其实质是函数式编程中的高阶函数，是对响应式编程的各个过程拆分封装后的产物。以便于我们操作数据流。按照其作用具体可分为以下几类：创建：创建一个可观察对象Observable并发射数据过滤：从Observable发射的数据中取出特定的值变换：对Observable发射的数据执行变换操作组合：组合多个Observable,例如：{1,2,3}+{4,5,6}-->{1,2,3,4,5,6} 聚合：聚合多个Observable，例如：{1,2,3}+{4,...

RxJava2详细攻略（上）【代码】【图】

0.简介 RxJava其实就是提供一套异步编程的API，这套API是基于观察者模式的，而且是链式调用的，所以使用RxJava编写的代码的逻辑会非常简介。 RxJava有三个基本元素：1.被观察者(Observable) 2.观察者（Observer) 3.订阅(subscribe)下面来说说以上三者是如何写作的：首先在gradle文件中添加依赖： implementation 'io.reactivex.rxjava2:rejava.2.1.4' implementation 'io.reactivex.rxjava2.2.0.0'1.创建被观察者 Observable obse...

RxJava2和Retrofit2封装教程（整洁、简单、实用）

前言 RxJava2与Retrofit2是老搭档了，之前写了一篇《RxJava和Retrofit2的统一处理单个请求》，是用的Rxjava1.0，本次使用Rxjava2.0与Retrofit2进行封装，一样整洁、简单、实用。Rxjava2相比Rxjava1优化和改动不少了东西，网上有很多大神写的文章，这里就不粘贴复制了。封装的过程有什么问题、疑问，请在下方留言。下面话不多说了，来一起看看详细的介绍吧封装教程如下：核心网络请求： package com.lin.netrequestdemo.data; im...

更新到RxJava2时出现“没有类型变量R的实例,因此Observable符合Observable”错误【代码】

我正在尝试使用翻新和rxJava调用API.使用RxJava 1时,以下代码似乎运行良好,但是一旦我更新到RxJava 2,就会收到此错误：错误：No Instance of type variable R exist so that Observable conforms toObservable阿皮Observable<HttpResult<List<Article>>> getList(@Query("key")String key);api请求在这里完成,这就是我在.map运算符内收到此错误的地方Observable cache=providers.getList().map(new HttpRsltFunc<List<Article>>()...

android-使用rxjava2遍历列表【代码】

我有一个自定义对象列表(List< Item> itemsList).这是我的自定义课程：public class Item {private String itemId;private String itemName; }初始列表只有itemName； itemId将为空.我想遍历列表,为每个项目添加一个itemId,然后使用新列表,我需要对列表中的每个项目进行某种长时间的操作.for(Item item : itemsList){ item.setitemId = getUniqueId(); //getUniqueId() returns an unique id doSomeLongOperation(item); }我是rxja...

Rxjava2阻止订阅与订阅【代码】

我已经阅读了有关blockingSubscribe()和subscribe()的解释,但是我既无法编写代码,也没有找到示例来查看它们之间的区别.看来这两种方式都是相同的.有人可以提供这两个示例,最好是用Java.解决方法:BlockingSubscribe阻止当前线程并在该线程上处理incomnig事件.您可以通过运行一些异步源看到这一点：System.out.println("Before blockingSubscribe"); System.out.println("Before Thread: " + Thread.currentThread());Observable.int...

如何在RxJava2中链接两个Completable【代码】

我有两个可完成的.我想做以下场景：如果第一个Completable到达onComplete,继续第二个Completable.最终结果将是第二次完成的完成. 当我有单个getUserIdAlreadySavedInDevice()和Completable login()时,我就是这样做的：@Override public Completable loginUserThatIsAlreadySavedInDevice(String password) {return getUserIdAlreadySavedInDevice().flatMapCompletable(s -> login(password, s))}解决方法:您正在寻找andThen操作符...

RxJava2 observable抛出UndeliverableException【代码】

据我所知,RxJava2 values.take(1)创建另一个Observable,它只包含原始Observable中的一个元素.哪个不能抛出异常,因为它被take(1)的效果过滤掉,因为它发生在第二个. 如下面的代码片段所示Observable<Integer> values = Observable.create(o -> {o.onNext(1);o.onError(new Exception("Oops"));});values.take(1).subscribe(System.out::println,e -> System.out.println("Error: " + e.getMessage()),() -> System.out.println("Comp...

rxjava2的使用（1）

Rxjava 的使用 github地址：https://github.com/ReactiveX/RxJava 参考自： https://mcxiaoke.gitbooks.io/rxdocs/content/ https://blog.csdn.net/weixin_36709064/article/details/82919785 https://www.jianshu.com/p/25682d620320 https://blog.csdn.net/jdsjlzx/article/details/54845517 rxjava ：一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库了解 ReactiveX ： ReactiveX 是一个专注于异步编程与...

RxJava2：不要在`repeatWhen`中重复【代码】

我有一个Observable我想定期重复,但只是在一个条件下：apiInterface.getData() // returns Observable<Data> ... // processing is happening here .toList() .repeatWhen(completed -> {if (autoReload){// Repeat every 3 secondsreturn completed.delay(3, TimeUnit.SECONDS);} else {return ??? // What do I have to return that it does not repeat?} }) .subscribe(list -> callbackInterface.success(list));我的问题是：我...

Android Room中的交易与RxJava2【代码】

我的应用程序的一个要求是允许用户进行多个步骤,然后在完成时根据每个步骤中的条目将值写入数据库. UI中的每个步骤都可能有助于需要写入数据库的操作.数据可以在多个表中,并且属于这些表中的不同行.如果任何数据库操作失败,则整个操作应该失败. 我最初考虑将所有数据加载到内存中,操作它,然后简单地在每个可能的实体中调用更新方法(冲突策略为REPLACE),但内存中可能存在极大量的数据. 我认为我可以组装一个List,其中显示中的每个Fr...

android – RxJava2如何将Single链接到Completable,以便在Completable完成时获得订阅【代码】

如何将Single链接到Completable,以便在Completable完成时获得订阅？ repository.downloadUser()是Single. 基于调试,似乎调用此方法中的Single但从未订阅(即,调用downloadUser()方法,但调用它所创建的Single内的代码). 问题是,如何使用原始订阅者获取repository.downloadUser()Single在链中订阅？我错过了什么或做错了什么？或者这不可能吗？fun login(username: String, password: String): Completable { return repository.lo...

RxJava2：首先替代rx.Observable方法(谓词)【代码】

我想使用RxJava但不能提出替代方法public final Observable<T> first(Func1<? super T,java.lang.Boolean> predicate)在RxJava2中. 我想做的是：return io.reactivex.Observable.concat(source1, source2, source3, source4).first(obj -> obj != null);参数source1到source4是我连接的io.reactivex.Observable实例,我希望结果Observable只发出非空的第一个项,但这当然会失败,因为io.reactivex.Observable没有方法(Func1)谓词)像rx...

android – 用Dagger 2和RxJava2包装SharedPreferences【代码】

我是否需要包装Android SharedPreferences类？如果是的话,能否请您提供一个简单的工作示例？我知道如何使用SharedPreferences,但是当涉及到包装它并提供Dagger 2和RxJava2时,我很困惑.解决方法:我通常只使用名为LocalStorage的接口或类似的东西来包装它.然后将一个Context注入实现并像往常一样实现您的SharedPreferences.如果你想使用Rx,只需确保你的接口方法返回Observables. 然后,只要你需要使用SharedPeferences,只需注入一个L...

首页 / JAVA / 如何在单元测试中处理模拟的RxJava2可观察抛出异常

如何在单元测试中处理模拟的RxJava2可观察抛出异常

内容导读

内容图文

内容总结

内容备注

内容手机端

【如何在单元测试中处理模拟的RxJava2可观察抛出异常】教程文章相关的互联网学习教程文章

JAVA2 - 相关标签

单元测试 - 相关标签

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程