验证 rxjava 订阅者中的交互

Question

以 MVP 模式描绘您的演示者订阅返回观察者的服务的情况：

public void gatherData(){
   service.doSomeMagic()
      .observeOn(Schedulers.io())
      .subscribeOn(AndroidSchedulers.mainThread())
      .subscribe(new TheSubscriber());
}

现在TheSubscriber 类从视图中调用onNext 一个方法，比如：

@Override public void onNext(ReturnValue value) {
  view.displayWhatever(value);
}

现在，在我的单元测试中，我想验证当在非错误情况下调用方法 gatherData() 时，调用视图的方法 displayWhatever(value)。

问题：

有没有干净的方法来做到这一点？

背景：

• 我正在使用 mockito 来验证交互，当然还有更多
• Dagger 正在注入除TheSubscriber 之外的整个演示者

我尝试了什么：

• 注入订阅者并在测试中模拟它。对我来说看起来有点脏，因为如果我想更改演示者与服务交互的方式（不是 Rx），那么我需要更改很多测试和代码。
• 模拟整个服务。这还不错，但需要我模拟很多方法，但我并没有完全达到我想要的效果。
• 在互联网上四处查找，但似乎没有人有一种干净直接的方法来做到这一点

感谢您的帮助

Answer 1

假设您以类似的方式使用service 和view 的接口：

class Presenter{
  Service service;
  View view;

  Presenter(Service service){
    this.service = service;
  }

  void bindView(View view){
    this.view = view;
  }

  void gatherData(){
    service.doSomeMagic()
      .observeOn(Schedulers.io())
      .subscribeOn(AndroidSchedulers.mainThread())
      .subscribe(view::displayValue);
  }
}

然后可以提供模拟来控制和验证行为：

@Test void assert_that_displayValue_is_called(){
  Service service = mock(Service.class);
  View view = mock(View.class);
  when(service.doSomeMagic()).thenReturn(Observable.just("myvalue"));
  Presenter presenter = new Presenter(service);
  presenter.bindView(view);

  presenter.gatherData();

  verify(view).displayValue("myvalue");
}

Answer 2

我知道它已经很晚了，但它可能对某人有所帮助，因为我搜索了很长时间来寻找您问题的解决方案：D

对我来说，添加Observable.Transformer<T, T> 如下：

    void gatherData() {
        service.doSomeMagic()
          .compose(getSchedulerTransformer())
          .subscribe(view::displayValue);
    }

    private <T> Observable.Transformer<T, T> getSchedulerTransformer() {
        if (mTransformer == null) {
            mTransformer = (Observable.Transformer<T, T>) observable -> observable.subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread());
        }

        return mTransformer;
    }

    void setSchedulerTransformer(Observable.Transformer<Observable<?>, Observable<?>> transformer) {
        mTransformer = transformer;
    }

为了设置 Transformer，我刚刚通过了这个：

setSchedulerTransformer(observable -> {
            if (observable instanceof Observable) {
                Observable observable1 = (Observable) observable;
                return observable1.subscribeOn(Schedulers.immediate())
                        .observeOn(Schedulers.immediate());
            }
            return null;
        });

所以只需在您的测试中添加一个@Before 方法并调用presenter.setSchedulerTransformer，它应该能够测试这个:)

希望这会有所帮助并且可以理解：D