CommonBackoffTest.java 文件源码

/**
 * Test shows, that when the server responds with different error
 * {@link retrofit2.HttpException} than
 * {@link com.rzagorski.retrofitrx2errorhandler.backoff.BackoffStrategy backoff strategies} react to
 * ({@link java.net.SocketTimeoutException}) the execution ends immediately.
 * <br>
 * Test created by Robert Zagorski on 19.10.2016
 */
@Test
public void testCompletes2() throws Exception {
    mockWebServer.setDispatcher(new Dispatcher() {
        @Override
        public MockResponse dispatch(RecordedRequest request) throws InterruptedException {
            switch (mockWebServer.getRequestCount()) {
                case 1:
                    return new MockResponse().setResponseCode(500);
                case 2:
                    return new MockResponse().setResponseCode(404);
                case 3:
                    return MockWebServerUtils.getSuccessfulResponse();
                default:
                    return new MockResponse().setResponseCode(500);
            }
        }
    });
    RxCallAdapter rxCallAdapter = new RxCallAdapter.Builder()
            .addBackoffStrategy(Exponential.init()
                    .addThrowable(SocketTimeoutException.class)
                    .setBase(2)
                    .setMaxRetries(3).build())
            .addBackoffStrategy(Simple.init()
                    .addThrowable(SocketTimeoutException.class)
                    .setMaxRetries(3).build())
            .setLoggingEnabled(true)
            .build();
    GitHub github = createRetrofitInstance(mockWebServer.url("/").toString(),
            new RxErrorHandingFactory(rxCallAdapter));

    long startTime = System.currentTimeMillis();
    Observable observable = github.repos("square");
    TestObserver testObserver = observable.test();
    testObserver.awaitTerminalEvent();
    long endTime = System.currentTimeMillis();
    System.out.println((endTime - startTime));
    //four SocketTimeoutExceptions and 3 exponential backoff's
    assertTrue((endTime - startTime) <= (1) * MockWebServerUtils.ONE_SEC);
}