【发布时间】:2015-08-07 10:49:00
【问题描述】:
我正在写一个简单的测试,相当于:
Test fun testObservable() {
val returnedObservable = Observable.create(object : Observable.OnSubscribe<String> {
override fun call(t: Subscriber<in String>) {
t.onNext("hello")
t.onCompleted()
}
}).subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
val result = returnedObservable.toBlocking().first()
assertEquals("hello", result)
}
当.observeOn(AndroidSchedulers.mainThread()) 存在时,测试会无限期地在returnedObservable.toBlocking().first() 上阻塞。
有没有办法转换 observable 以返回结果?
returnedObservable 是从已应用 .subscribeOn 和 .observeOn 的方法调用返回的,因此不能选择删除它们。
【问题讨论】:
标签: java android rx-java android-testing kotlin