@Test
public void testHappyPath() throws InterruptedException, ExecutionException {

  ApiFuture<List<String>> result = callable.futureCall("request");
  MockServerStreamingCall<String, String> call = upstream.popLastCall();
  Truth.assertThat(call.getController().isAutoFlowControlEnabled()).isTrue();
  call.getController().getObserver().onResponse("response1");
  call.getController().getObserver().onResponse("response2");
  call.getController().getObserver().onComplete();
  Truth.assertThat(result.get()).containsExactly("response1", "response2").inOrder();
}