- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在测试单个用例。但是测试观察者不会在测试环境中发出任何东西。
subscribeOn()
从 Schedulers.newThread()
更改为TestScheduler()
仍然测试失败。我很困惑。我不知道是什么我在这里做错了吗?subscribeOn
,observeOn
方法然后测试成功通过。然后TestScheduler()
的实际用途是什么?以下是UseCase.kt
文件
abstract class UseCase<T>(val postExecutionThread: PostExecutionThread) {
abstract fun buildUseCaseBuilder(): Observable<T>
/**
* execute method for observables
*/
open fun execute(): Observable<T> {
return buildUseCaseBuilder()
.subscribeOn(Schedulers.newThread())
.observeOn(postExecutionThread.getScheduler())
}
}
在测试类之后加上上面的被测类
class UseCaseTest {
val postExecutionThread=Mockito.mock(PostExecutionThread::class.java)
val result: String="test"
val testObserver=TestObserver<String>()
@Before
fun setUp() {
_when(postExecutionThread.getScheduler()).thenReturn(TestScheduler())
}
@Test
fun `test execute method of use case`() {
println(" thread type ${postExecutionThread.getScheduler()}")
//test fail
//java.lang.AssertionError: Value count differs; Expected: 1 [test], Actual: 0 [] (latch = 1, values = 0, errors = 0, completions = 0)
TestUseCase(postExecutionThread).execute().test()
.assertResult(result)
//subscriber not print any thing
TestUseCase(postExecutionThread).execute().subscribe{
println("called $it")
}
}
inner class TestUseCase(postExecutionThread: PostExecutionThread?) : UseCase<String>(postExecutionThread!!) {
override fun buildUseCaseBuilder(): Observable<String> {
return Observable.just(result)
}
}
}
最佳答案
问题是,您的测试是在您使用 subscribeOn()
和 observeOn()
指定的线程以外的线程上运行的。你想要的是让测试和被测试的代码在同一个线程上同步运行,而不管 subscribeOn()
/observeOn()
中指定了什么。
您可以使用自定义 @Rule
来实现喜欢this one :
/**
* This rule registers Handlers for RxJava and RxAndroid to ensure that subscriptions
* always subscribeOn and observeOn Schedulers.trampoline().
* Warning, this rule will reset RxAndroidPlugins and RxJavaPlugins before and after each test so
* if the application code uses RxJava plugins this may affect the behaviour of the testing method.
*/
public class RxSchedulersOverrideRule implements TestRule {
private final Function<Callable<Scheduler>, Scheduler> mRxAndroidSchedulersHook =
new Function<Callable<Scheduler>, Scheduler>() {
@Override
public Scheduler apply(@NonNull Callable<Scheduler> schedulerCallable)
throws Exception {
return getScheduler();
}
};
private final Function<Scheduler, Scheduler> mRxJavaImmediateScheduler =
new Function<Scheduler, Scheduler>() {
@Override
public Scheduler apply(@NonNull Scheduler scheduler) throws Exception {
return getScheduler();
}
};
@Override
public Statement apply(final Statement base, Description description) {
return new Statement() {
@Override
public void evaluate() throws Throwable {
RxAndroidPlugins.reset();
RxAndroidPlugins.setInitMainThreadSchedulerHandler(mRxAndroidSchedulersHook);
RxJavaPlugins.reset();
RxJavaPlugins.setIoSchedulerHandler(mRxJavaImmediateScheduler);
RxJavaPlugins.setNewThreadSchedulerHandler(mRxJavaImmediateScheduler);
base.evaluate();
RxAndroidPlugins.reset();
RxJavaPlugins.reset();
}
};
}
public Scheduler getScheduler() {
return Schedulers.trampoline();
}
}
使用此代码,您可以拦截所有调度程序并使所有内容在 trampoline()
上运行调度程序。
现在只需将以下 @Rule
添加到您的测试中:
public class MyTestClass {
@Rule
public final RxSchedulersOverrideRule mOverrideSchedulersRule = new RxSchedulersOverrideRule();
@Test
public void someTest() {
...
}
}
关于android - 测试特定用例时 TestScheduler 不工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49358096/
我创建了以下辅助方法来协助测试可观察对象: public static void ExecuteObservableTest(IObservable observable, Action ac
我正在测试单个用例。但是测试观察者不会在测试环境中发出任何东西。 即使我将 subscribeOn() 从 Schedulers.newThread() 更改为TestScheduler() 仍然测试
根据一些评论,我应该明确表示这个问题是关于为什么 TestScheduler 会抛出空引用异常,而不是如何让测试通过。一个较早的示例假定与 TPL 的交互是问题的原因,但我现在发现这不是触发行为所必需
我正在尝试测试一个函数,其中流的元素在延迟后一个接一个地分派(dispatch),我能够使用 Thread.sleep 使我的测试工作。但是,当我使用 TestScheduler.advanceTim
当我这样做时: testScheduler.Schedule("Hello world",(scheduler, state) => Console.WriteLine(state)); testSc
我对 rx/ReactiveUi 非常陌生,想使用 TestScheduler 编写一个 xunit 测试来检查检索搜索建议的限制是否正常工作。 想法是使用 TestScheudler 进行计时,更改
我正在使用 RX 进行一些(非常基本的)事件订阅:- public void StartListening(IObservable observable) { subscription = ob
我试图让 Jasmine、promises 和 Rx.TestScheduler 一起很好地发挥作用,但我遇到了一个似乎无法解决的障碍。 我想要实现的是使用 RxJs 和 Jasmine 测试延迟 p
我正在尝试在 Kotlin 中使用 RxJava 在 MVP 架构中测试我的演示者。我创建了一个测试规则,用 TestScheduler 替换常用的调度程序,以便能够测试异步请求: class Tes
我正在尝试了解如何在 C# 中实现以下目标 我有这个类的列表 public class StockTickerChangeHistory { public DateTime Time;
我正在尝试在测试中使用带有异步方法的 reactiveui 测试调度程序。 等待异步调用时测试挂起。 根本原因似乎是在异步方法中等待的命令。 [Fact] public async T
我一直面临主题和 TestScheduler 的问题。如果我使用 Trampoline 调度程序,我的测试会通过,但由于某种原因,如果我使用 TestScheduler,测试会失败。 这是我的示例测试
这很愚蠢,但我似乎找不到包含 TestScheduler 的 .net rx nuget 包 请指出正确的方向。 最佳答案 TestScheduler 在 Microsoft.Reactive.Tes
所以我正在尝试在使用 Akavache 的应用程序中测试缓存行为。我的测试看起来像这样: using Akavache; using Microsoft.Reactive.Testing; using
我有一个测试代码的例子: [Fact] public void Should_only_contain_most_recent() { var window = Tim
我正在尝试在 RxJs 版本 5 中使用 Observable.interval 编写示例单元测试。我正在运行以下代码,但我的 observable 只触发一次,而不是预期的 20 次. it('do
我想编写一个单元测试来验证下面的 callInit 方法。但是,我在该行包含 subscribe( 的地方遇到了空指针异常。我的问题是如何在下面的方法中验证 onnext 和 onerror 条件?
tl;dr 是否可以在不重写的情况下对这段代码进行单元测试? http://jsbin.com/jezosegopo/edit?js,console const keyUpObserver = ($i
我想检查我创建的 IObservable 是否尊重“完成后,我将取消订阅你” 的礼貌。乍一看,我的代码似乎有问题。但是删除我的代码,只使用 TestScheduler 提供的 Observable 和
我是 ReactiveUI 的新手。我有以下简单设置:可以指定 csv 的路径,并将包含的数据点显示给用户(使用 oxyplot)。现在我正在尝试测试以下订阅: public GraphViewMod
我是一名优秀的程序员,十分优秀!