RxOkHttpClient implements RxHttpClient { @Override public Observable<Response> get(String url) { Request request = new Request.Builder() .url(url) .get() .build(); return execute(request); } RxOkHttpClient(Builder builder); @Override Observable<Response> execute(Request request); @Override Observable<Response> get(String url); @Override Observable<Response> head(String url); @Override Observable<Response> post(String url, Object entity); @Override Observable<Response> delete(String url); @Override Observable<Response> delete(String url, Object entity); @Override Observable<Response> put(String url, Object entity); @Override Observable<Response> patch(String url, Object entity); SSLContext sslContext(); X509TrustManager trustManager(); List<Interceptor> interceptors(); static Builder newBuilder(); static Builder newBuilder(RxOkHttpClient rxOkHttpClient);  }
@Test public void testGet() throws Exception { MockResponse mockResponse = new MockResponse() .setBody(TEST_RESPONSE_BODY) .setResponseCode(StatusCode.OK.getCode()); server.enqueue(mockResponse); RxHttpClient client = RxOkHttpClient.newBuilder() .build(); Request request = new Request.Builder() .url(server.url("/").toString()) .get() .build(); Response response = client.execute(request).toBlocking().first(); Assertions.assertThat(response.isSuccessful()).isTrue(); InputStream inputStream = response.getBody().get(InputStream.class); String actualResponseBody = CharStreams.toString(new InputStreamReader(inputStream, Charsets.UTF_8)); Assertions.assertThat(actualResponseBody).isEqualTo(TEST_RESPONSE_BODY); RecordedRequest recordedRequest = server.takeRequest(1, TimeUnit.MILLISECONDS); Assertions.assertThat(recordedRequest).isNotNull(); Assertions.assertThat(recordedRequest.getBodySize()).isLessThanOrEqualTo(0); }