subscriber.requestMore(Long.MAX_VALUE); // Subsequent requests do not trigger HTTP requests.
assertThat(server.getRequestCount()).isEqualTo(1);
}
@Test public void responseSuccess200() {
server.enqueue(new MockResponse().setBody("Hi"));
<BUG>BlockingObservable<Response<String>> o = service.response().toBlocking();
Response<String> response = o.first();
assertThat(response.isSuccessful()).isTrue();
assertThat(response.body()).isEqualTo("Hi");
}</BUG>
@Test public void responseSuccess404() throws IOException {

subscriber.requestMore(Long.MAX_VALUE); // Subsequent requests do not trigger HTTP requests.
assertThat(server.getRequestCount()).isEqualTo(1);
}
@Test public void responseSuccess200() {
server.enqueue(new MockResponse().setBody("Hi"));
TestSubscriber<Response<String>> subscriber = new TestSubscriber<>();
service.response().subscribe(subscriber);
Response<String> response = subscriber.getOnNextEvents().get(0);
assertThat(response.isSuccessful()).isTrue();
assertThat(response.body()).isEqualTo("Hi");
subscriber.assertCompleted();
}
@Test public void responseSuccess404() throws IOException {
