单元测试：如何验证和模拟在Android中的RxJava中完成一个可观察的

Question

我试图写一些单元测试的Android应用程序是使用改造2， Mockito 1.10和RXJava 1.0.我没有使用支持lambdas的java版本！

我的代码使用可观测的，我可以做到以下几点：

when(myAPI.Complete(anyString(), any(MyContainer.class)))
        .thenReturn(Observable.<GenericResponse>error(new Throwable("An error has occurred!")));

Subscriber genericResponseSubscriber = mock(Subscriber.class);

myPresenter.myUseCase(id, container, genericResponseSubscriber);

verify(genericResponseSubscriber, times(1)).onError(any(Throwable.class));

上面的代码运行良好，允许我抛出错误并在测试中捕获它。

我也需要能够做的（当然）：）是捕捉积极的条件。我觉得这很明显，但找不到我需要的答案。

如何捕获onComplete和onNext案例？

我知道onComplete的验证将是。。。

验证（genericResponseSubscriber，次（1））。未完成（）；

但我看不出我的when子句应该是什么。我尝试了以下方法，但失败了：

GenericResponse response = new GenericResponse();
response.setSuccess(true);

when(myAPI.orderComplete(anyString(), any(MyContainer.class)))
        .thenReturn(Observable.just(response));

Subscriber genericResponseSubscriber = mock(Subscriber.class);

myPresenter.myUseCase(id, container, genericResponseSubscriber);

verify(genericResponseSubscriber, times(1)).onCompleted();

这里的失败之处在于调用了subscriber.onStart（）。

因此，我想知道的是，我如何模拟和验证“onComplete”和“onNext”调用，更重要的是，我本应该自己解决这个问题，而不是去问！）

和往常一样，我们非常感谢您的帮助。

编辑

我的一个错误工作测试用例。。

    public void UseCaseOnError() throws Exception {
        
     String id = "5";
    
        
     order Order = new Order();
        
     SomeContainer myContainer = new SomeContainer(order);
    
        

     when(myRetroFitAPI.complete(anyString(), any(SomeContainer.class)))

.然后返回（Observable.error（新的Throwable（“我的错误”））；
 


     Subscriber genericResponseSubscriber = mock(Subscriber.class);
    
        

     orderPresenter.doUseCase(id, myContainer, genericResponseSubscriber);
    
        

     verify(genericResponseSubscriber,times(1)).onError(any(Throwable.class));
    
    

}

我真正需要补充的是，我觉得就积极状态而言，onError应该有一个等价物，即未完成。如果我也这样做，但使用onCompleted，我的验证将失败，因为它检测到onStart已被调用，这让我感到相当困惑。

我已尝试将ReplaySubject用作：

public void createOrderOnCompleteError() {
    orderOnCompleteSubject.onError(new Throwable("I am an error"));
}

public void createOrderOnCompleteSuccess() {
    orderOnCompleteSubject.onNext(new GenericResponse().setSuccess(true));
    orderOnCompleteSubject.onCompleted();
}

错误机制工作正常...完成的机制不...

Answer 1

简单的方法是尝试抛出一个模拟异常，而不是真正的异常。

@Mock
Exception mockException;

observer.onError(mockException); 

Answer 2

您应该为RxJava 1创建一个测试订阅服务器，而不是嘲笑订阅服务器：

when(myAPI.Complete(anyString(), any(MyContainer.class)))
        .thenReturn(Observable.<GenericResponse>error(new Throwable("An error has occurred!")));

TestSubscriber genericResponseSubscriber = TestSubscriber.create();

myPresenter.myUseCase(id, container, genericResponseSubscriber);

// To check for an error
genericResponseSubscriber.assertError(Throwable.class)

// To check for completion
genericResponseSubscriber.assertCompleted()

您可能需要更具体地说明您期望的错误类。查看测试订阅者文档。你可以用这个类验证很多东西。

快乐测试！

Answer 3

您应该使用类Test观察员来测试可观察的，通过以下方式：

public Observable<Integer> getObservable() {
     return Observable.just(12, 20, 330);
}

@Test
public void testObservable() {
     Observable<Integer> obs = getObservable();
     TestObserver<Integer> testObserver = TestObserver.create();
     obs.subscribe(testObserver);

     testObserver.assertComplete();
     testObserver.assertResult(12, 20, 330);
 }

通过这种方式，您可以验证它是否完成并发出所有预期的项目。

如果您想创建observable的模拟版本，您可以创建一个新的observable，它具有您想要的行为。例如：

public Observable<Integer> mockedObservableCompleteWithResult() {
        return Observable.create(e -> {
            e.onNext(12);
            e.onNext(20);
            e.onNext(330);
            e.onComplete();
        });
    }

这可以通过上述测试进行验证。

然后我们可以创建其他模拟来模拟其他结果

public Observable<Integer> mockedObservableError() {
            return Observable.create(e -> {
                e.onNext(12);
                e.onError(new Throwable("Generic exception"));
            });
        }

可以验证的是：

@Test
public void testObservable() throws Exception {
       Observable<Integer> obs = mockedObservableError();
       TestObserver<Integer> testObserver = TestObserver.create();
       obs.subscribe(testObserver);

       testObserver.assertError(Throwable.class);
}