验证rxjava订阅服务器中的交互

Question

想象一下MVP模式中的情况，演示者订阅了一个返回观察者的服务：

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

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

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

现在，在我的单元测试中，我想验证在非错误情况下调用方法gatherData（）时，是否调用了视图的方法displaything（value）。

问题是：

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

背景：

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

我试过什么：

• 注入订阅服务器并在测试中模拟它。看起来有点脏，因为如果我想改变演示者与服务交互的方式（比如说不是Rx），那么我需要更改很多测试和代码

谢谢你的帮助

Answer 1

我知道现在已经很晚了，但希望它能帮助一些人，因为我一直在寻找你问题的答案：D

对我来说，结果是增加了一个可观察的。变压器

    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;
    }

为了设置变压器，我刚刚通过了这个：

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

所以只需在测试中添加一个@前方法，并调用presenter.setSchedulerTransform，它应该能够测试这个：）

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

Answer 2

假设您正在以类似的方式使用服务和视图的接口：

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");
}