Mockito-当使用RXJava2.retry（）进行排列时

Question

public class Foo {

    private Bar bar;

    public Foo(Bar bar) {
        this.bar = bar;
    }

    public Completable execute() {
        return Completable.fromAction(() -> System.out.println("first part of task"))
                .andThen(bar.dangerousMethod()
                        .retry(10)
                )
                .andThen(Completable.fromAction(() -> System.out.println("sec part of task")));
    }
}


public interface Bar {
    Completable dangerousMethod();
}

@Mock private Bar bar;
@InjectMocks private Foo foo;

@Test
public void test() throws Exception {
    when(bar.dangerousMethod()).thenReturn(
            error(new Exception()),
            error(new Exception()),
            complete()
    );

    foo.execute()
            .test()
            .assertComplete();
}

如何以正确的方式使用Mockito测试.retry()方法？

Answer 1

您不应该测试这个方法，因为它不是代码的一部分，而且（我希望）编写RxJava库的人已经对它进行了很好的测试。

但无论如何，如果你想测试你能做到：

将when语句替换为：

   when(bar.dangerousMethod()).thenReturn(
                Completable.defer(new Callable<CompletableSource>() {
                    boolean fail = true;
                    @Override
                    public CompletableSource call() throws Exception {
                        if(fail) {
                            fail = false;
                            return Completable.error(new Exception());
                        } else {
                            return Completable.complete();
                        }
                    }
                }));