java - 测试 RxJava2 doOnComplete()

Question

正如您从下面的代码中看到的，我正在尝试测试在我的存储库中发生的 doOnComplete() 调用的行为。但是，当我模拟客户端的注入(inject)依赖项时，我使用 Observable.just() 返回项目，不再调用 doOnComplete()。根据 RxJava2，我相信这是故意的。我不确定如何解决这个问题。

@Singleton
public class Repository {
    private SomeNetworkClient client;
    private SomeCache cache;

    @Inject
    public Repository(SomeNetworkClient client, SomeCache cache) {
        this.client = client;
        this.cache = cache;
    }

    public Observable<SomeItem> getSomeItem() {
        return client.getSomeItem()
                .doOnComplete(() -> cache.doThisOnComplete())
                .doOnError(throwable -> someError);
    }
}

public class RepositoryTest {
    private Repository testedRepository;
    @Mock
    SomeNetworkClient client;
    @Mock
    SomeCache cache;
    @Mock
    SomeItem someItem;

    @Before
    public void setup() {
        MockitoAnnotations.initMocks(this);
        testedRepository = new Repository(client, cache);
        when(client.getSomeItem())
            .thenReturn(Observable.just(someItem));
    }

    @Test
    public void thisTestFails() {
        testedRepository.getSomeItem().blockingFirst();
        // This fails because it appears that mocking with
        // Observable.just() makes doOnComplete() not be invoked.
        verify(cache.doThisOnComplete());
    }
}

Answer 1

你代码中的问题是，blockingFirst()不会关心听完整的事件发生。它会立即返回流中的第一项和dispose from observable。 .

相反，您可以这样执行断言:

    testedRepository
            .getSomeItem()
            .test()
            .assertComplete()