java - 使用 TestSubscriber 测试 RxJava 异常

Question

我正在尝试为一个函数编写测试用例，如果验证通过，则返回一些数据，否则抛出异常

private String validate(Test test) {
    //Validation Logic which returns null or throws Exception

    }

    public Observable<Test> create(Test test) {
        return Observable
                .just(validate(test))
                .flatMap(x -> testRepository
                        .create(test));
    }

相同的测试用例

@Test
    public void Should_ThrowException_When_NoData() {
       Test test = sampleTest();
        TestSubscriber<Test> subscriber = new TestSubscriber<>();
        testService
                .create(test)
                .subscribe(subscriber);
        subscriber.awaitTerminalEvent();
        Throwable thrown = subscriber.getOnErrorEvents().get(0);
        assertThat(thrown)
                .isInstanceOf(CustomException.class)
                .hasFieldOrPropertyWithValue("errorId", 102);

    }

但是测试用例在 testService.create 本身上失败了。

这里有什么问题吗？

谢谢

Answer 1

它会失败，因为您在使用其返回值创建 Observable 之前调用了 validate()。相反，您可以调用 fromCallable(() -> validate(test)) 并推迟 validate 的执行。