假设接口定义如下：
public interface MyService { @GET("/name") rx.Observable<String> name();}通话将被转发到
MyServiceMock使用
BehaviorDelegate。将
BehaviorDelegate适用
NetworkBehavior于由模拟产生的反应。请注意，下面的模拟实现将
BehaviorDelegate用作构造函数参数，并使用它返回响应。
public class MyServiceMock implements MyService { private final BehaviorDelegate<MyService> delegate; public MyServiceMock(BehaviorDelegate<MyService> delegate) { this.delegate = delegate; } public Observable<String> name() { return delegate.returningResponse("test").name(); }}使用模拟服务的测试示例如下所示：
public class MyServiceTest { private final NetworkBehavior behavior = NetworkBehavior.create(); private final rx.observers.TestSubscriber<String> testSubscriber = TestSubscriber.create(); private MyService mockService; @Before public void setUp() throws Exception { Retrofit retrofit = new Retrofit.Builder() .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .baseUrl("http://example.com").build(); MockRetrofit mockRetrofit = new MockRetrofit.Builder(retrofit) .networkBehavior(behavior).build(); final BehaviorDelegate<MyService> delegate = mockRetrofit.create(MyService.class); mockService = new MyServiceMock(delegate); } @Test public void testSuccessResponse() throws Exception { givenNetworkFailurePercentIs(0); mockService.name().subscribe(testSubscriber); testSubscriber.assertValue("test"); testSubscriber.assertCompleted(); } @Test public void testFailureResponse() throws Exception { givenNetworkFailurePercentIs(100); mockService.name().subscribe(testSubscriber); testSubscriber.assertNoValues(); testSubscriber.assertError(IOException.class); } private void givenNetworkFailurePercentIs(int failurePercent) { behavior.setDelay(0, MILLISECONDS); behavior.setVariancePercent(0); behavior.setFailurePercent(failurePercent); }}
